Interesting thought. What is the objective? To ensure we recover from an unclean shutdown as well? If so, then I think we actually need to do more, since uncaught exceptions cause Streams to shut down cleanly, which isn't much different that calling `driver.close()`, if I'm thinking clearly.
I guess we could spawn an external process and forcibly kill it at this point. Should we do something like that here, or write a system test for it? [ Full content available at: https://github.com/apache/kafka/pull/5724 ] This message was relayed via gitbox.apache.org for [email protected]
