Guess it is a question for Colin, who is the RM for 3.9.
-Matthias On 8/30/24 2:02 AM, Sebastien Viale wrote:
Hi, All PRs related to KIP-1033 have been merged. However, after a last review from Matthias J. Sax and Bill Bejeck, we updated the KIP to include the timestamp in the ErrorHandlerContext interface. A new PR has been initialized. KAFKA-16448 Add timestamp to error handler context (https://github.com/apache/kafka/pull/17054) Please let us know if we need to work on this for 3.9 or for next release. thanks very much Sébastien ________________________________ De : Matthias J. Sax <mj...@apache.org> Envoyé : jeudi 1 août 2024 23:46 À : dev@kafka.apache.org <dev@kafka.apache.org> Objet : [EXT] Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing Warning External sender Do not click on any links or open any attachments unless you trust the sender and know the content is safe. Thanks Loïc! ======================================================================================== This email was screened for spam and malicious content but exercise caution anyway. On 8/1/24 6:19 AM, Loic Greffier wrote: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 attributes present in the ErrorHandlerContext have been removed from this KIP. They will be part of KIP-1034 instead. * The number of processing exception handler instance has been fixed to one per StreamTask. * The processing exception handling mechanism has been extended to punctuations. * The handler crash management has been unified and improved. Exceptions thrown from a call to #handle are caught and fail the stream. This change covers 5 use-cases: * On processingExceptionHandler#handle to cover processing exceptions. * On processingExceptionHandler#handle to cover punctuation exceptions. * On productionExceptionHandler#handle to cover production exceptions. * On productionExceptionHandler#handleSerializationException to cover serialization exceptions. * On deserializationExceptionHandler#handle to cover deserialization exceptions. KIP-1033 has been updated with these changes. Loïc
