Description
In BrokerProxy.stop, the call to thread.interrupt doesn't always lead to a real thread interruption, which can cause shut down to not occur. One workaround is to repeatedly call thread.interrupt in a tight while loop until thread.isAlive returns false.
Related mailing list thread: http://www.mail-archive.com/dev@samza.incubator.apache.org/msg02255.html
Attachments
Issue Links
- is depended upon by
-
SAMZA-506 Shutdown container on SIGTERM
- Resolved
- relates to
-
KAFKA-1886 SimpleConsumer swallowing ClosedByInterruptException
- Resolved