fix ConcurrentModificationException in KafkaIO#290

Closed

rangadi wants to merge 5 commits intoapache:masterfrom

rangadi:shutdown

Commits on May 5, 2016

- after shutting down, wait for the threads to actually finish
Raghu Angadi
committed
check closed flag to reduce race window further
Raghu Angadi
committed
rearrange comments and the while loop a bit
Raghu Angadi
committed
fix checkstyle error
Raghu Angadi
committed
set interrupt flag
Raghu Angadi
committed