Permissions to create or update KIPs

Hello, I would like to have permissions to create or update KIPs. My Confluence ID and Jira ID are "loicgreffier" for both. Thanks!

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

Hi, Last PR that completed KIP-1033 has been merged. Thanks to all participants, for the guidance and the feedbacks! Just letting you know about some decisions and changes made through the different PRs that were not initially mentioned in the KIP: * The sourceRawKey and the sourceRawValue

Re: [DISCUSS] Apache Kafka 3.9.0 release

Hello, Can KIP-1033 https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occurring+during+processing be included in this release? Most of the PRs related to this KIP have been reviewed and merged. There are 3 additional less complex P

[VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing

Hi everyone, A first pull request has been opened: https://github.com/apache/kafka/pull/16090. As Bruno mentioned in the following discussion: https://github.com/apache/kafka/pull/16090#discussion_r1616264629, we bring a minor change to KIP-1033 by renaming both ProcessingExceptionHandler imp

[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 reco

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 l

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 "dea

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(); streamProps.put(StreamsConfig.DEFAULT_PROCESS_EXCEPTION_HANDLER_CLASS_CONF

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 « DOTI/BS/