ableegoldman opened a new pull request #11381: URL: https://github.com/apache/kafka/pull/11381
In the current exception handler, there's not much granularity and all exceptions from all sources are treated equally. With the introduction of independent named topologies, it would be nice to have some way to differentiate which topology an exception was thrown from during processing. Currently we only consider exceptions thrown from the `process()` method of a task in that named topology, but eventually we can expand this to other exceptions that are tied to a particular topology, for example errors pertaining to the topics of that query -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
