Thanks for reporting the problem! It did get fixed in current trunk already: https://issues.apache.org/jira/browse/KAFKA-4366
You could build Kafka Streams from the sources by yourself to check if the fix resolves your issues. -Matthias On 11/17/16 6:10 PM, Ara Ebrahimi wrote: > This happens for me too. On 10.1.0. Seems like it just sits there waiting in > the streamThread.join() call. > > Ara. > >> On Nov 17, 2016, at 6:02 PM, mordac2k <morda...@gmail.com> wrote: >> >> Hello all, >> >> I have a Java application in which I use an instance of KafkaStreams that >> is working splendidly, under normal circumstances. >> >> However, during development testing, I am using a single kafka instance >> (0.10.1.0) as the broker. When this single broker is not running, sending >> SIGTERM to my application causes it to hang on streams.close(). >> >> This hang appears to be indefinite, it does not appear to ever time out. >> Funny enough, if, during this hang, the broker comes back online, the close >> will continue and the application will terminate properly as a result of >> the original SIGTERM. >> >> I've tried this with broker configurations where the partition count is set >> to 1 and 2, with the same result in both scenarios. >> >> (FWIW: I scanned the archive of this ML looking for previous instances of >> this issue, and did not find one concerning streams specifically) >> >> Any thoughts? >> >> Thanks. >> >> >> >> ________________________________ >> >> This message is for the designated recipient only and may contain >> privileged, proprietary, or otherwise confidential information. If you have >> received it in error, please notify the sender immediately and delete the >> original. Any other use of the e-mail by you is prohibited. Thank you in >> advance for your cooperation. >> >> ________________________________ > > > > > ________________________________ > > This message is for the designated recipient only and may contain privileged, > proprietary, or otherwise confidential information. If you have received it > in error, please notify the sender immediately and delete the original. Any > other use of the e-mail by you is prohibited. Thank you in advance for your > cooperation. > > ________________________________ >
signature.asc
Description: OpenPGP digital signature
