kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ara Ebrahimi <ara.ebrah...@argyledata.com>
Subject Re: Hang while close() on KafkaStream
Date Fri, 18 Nov 2016 02:10:05 GMT
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 <mordac2k@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.

________________________________

Mime
View raw message