Hello all, I would like to discuss the following KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-779%3A+Allow+Source+Tasks+to+Handle+Producer+Exceptions The main purpose is to allow Source Tasks the ability to see underlying Producer Exceptions and decide what to do rather than being killed. In our use cases we would want to log/write off some information and continue processing. PR is here: https://github.com/apache/kafka/pull/11382 Any comments and feedback are welcome. Knowles
