Thanks for the KIP. It seem that the new exception would need to be thrown by user code? However, in the motivation you mention the scenario of a missing source topic that a user cannot detect, but KafkaStreams runtime would be responsible to handle.
How do both things go together? -Matthias On 9/11/20 10:31 AM, Walker Carlson wrote: > Hello all, > > I have created KIP-671 to give the option to shutdown a streams > application in response to an error. > https://cwiki.apache.org/confluence/display/KAFKA/KIP-671%3A+Shutdown+Streams+Application+when+appropriate+exception+is+thrown > > This is because of the Jira ticket > <https://issues.apache.org/jira/browse/KAFKA-9331> > > Please give it a look and let me know if you have any feedback. > > Thanks, > Walker >
signature.asc
Description: OpenPGP digital signature
