[ 
https://issues.apache.org/jira/browse/KAFKA-12281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007713#comment-18007713
 ] 

Rajani Karuturi commented on KAFKA-12281:
-----------------------------------------

[~mjsax] In addition to BrokerNotFoundException which is unused since 2.8, 
there are few methods marked deprecated in some of the exception 
handlers(updated the details in description of this issue) since 3.9. 

Plan is to remove those in favor of the newer ones. 

Should these changes go in 5.0 release? 

 

> 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)

Reply via email to