[DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Hi Matthias, To sum up with the ProductionExceptionHandler callback methods (106) proposed changes. A new method ProductionExceptionHandler#handle is added with the following signature: > ProductionExceptionHandlerResponse handle(final ErrorHandlerContext context, > final ProducerRecord

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Hi Bruno, Good catch, KIP has been updated accordingly. Regards, Loïc

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Hi Matthias, I have updated the KIP regarding points 103 and 108. 103. I have suggested a new `ImmutableHeaders` interface to deal with the immutability concern of the headers, which is basically the `Headers` interface without the write accesses. public interface ImmutableHeaders { Header

Re: [DISCUSS] KIP-1034: Dead letter queue in Kafka Streams

Hi Sophie, Thanks for your feedback. Completing the Damien's comments here for points S1 and S5B. S1: > I'm confused -- are you saying that we're introducing a new kind of > ProducerRecord class for this? I am wondering if it makes sense to alter the ProducerRecord from Clients API with a

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Hi Bruno and Bill, To complete the Damien's purposes about the point 3. Processing errors are caught and handled by the ProcessingErrorHandler, at the precise moment when records are processed by processor nodes. The handling will be performed in the "process" method of the ProcessorNode, such

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Hi, To complete the Sébastien's answer about the point 3, here is an example of how users could simply type the record key or value, based on a custom process exception handler: Properties streamProps = new Properties();

Subscribe to Developer mailing list

Hi @dev@kafka.apache.org, I am working as a Software Engineer at Michelin, and would like to subscribe to the Developer mailing list to be able to open a KIP and contribute to Apache Kafka. LoÏC GREFFIER GROUPE MICHELIN - Development Technology Specialist «