[ https://issues.apache.org/jira/browse/KAFKA-12281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007866#comment-18007866 ]
Matthias J. Sax commented on KAFKA-12281: ----------------------------------------- Let's do the discussion on the dev mailing list. I'll reply there. > cleanup deprecated exceptions in org.apache.kafka.streams.errors.* > ------------------------------------------------------------------ > > Key: KAFKA-12281 > URL: https://issues.apache.org/jira/browse/KAFKA-12281 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Chia-Ping Tsai > Assignee: Rajani Karuturi > Priority: Minor > Labels: beginner, needs-kip, newbie > Attachments: KIP-711.md, image-2025-07-15-11-24-19-092.png, > image-2025-07-16-09-23-11-101.png, image-2025-07-16-09-23-16-144.png, 螢幕快照 > 2025-07-16 12-00-00.png, 螢幕快照 2025-07-16 12-02-01.png > > > It's been 3 years since 234ec8a gets rid of usage of BrokerNotFoundException. > Hence, it is time to deprecate BrokerNotFoundException. > > *Deprecated Class for Removal:* > * {{org.apache.kafka.streams.errors.BrokerNotFoundException}} > *Deprecated Methods for Removal:* > * > {{org.apache.kafka.streams.errors.DefaultProductionExceptionHandler.handle(final > ProducerRecord<byte[], byte[]> record, final Exception exception)}} and the > interface method > {{org.apache.kafka.streams.errors.ProductionExceptionHandler.handle(final > ProducerRecord<byte[], byte[]> record, final Exception exception)}} > * > {{org.apache.kafka.streams.errors.ProductionExceptionHandler.handleSerializationException(final > ProducerRecord record, final Exception exception)}} > * > {{org.apache.kafka.streams.errors.DeserializationExceptionHandler.handle(final > ProcessorContext context, final ConsumerRecord<byte[], byte[]> record,final > Exception exception)}} > * > {{org.apache.kafka.streams.errors.LogAndContinueExceptionHandler.handle(final > ProcessorContext context, final ConsumerRecord<byte[], byte[]> record,final > Exception exception)}} > * {{org.apache.kafka.streams.errors.LogAndFailExceptionHandler.handle(final > ProcessorContext context, final ConsumerRecord<byte[], byte[]> record, > finalException exception)}} > The {{BrokerNotFoundException}} class was deprecated in Kafka Streams 2.8 and > it is no longer used internally. > The listed methods were deprecated in Kafka Streams version 3.9, with newer > {{handle}} methods (that include {{{}ErrorHandlerContext{}}}) provided as > replacements. -- This message was sent by Atlassian Jira (v8.20.10#820010)