Re: Hang while close() on KafkaStream

2016-11-17 Thread Matthias J. Sax
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

Re: Hang while close() on KafkaStream

2016-11-17 Thread Ara Ebrahimi
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 wrote: > > Hello all, > > I have a Java application in which I use an instance of KafkaStreams that > is working splendidly, under normal circu

Hang while close() on KafkaStream

2016-11-17 Thread mordac2k
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 a