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.
