[jira] [Created] (KAFKA-7522) As a client of kafka-streams library I want to provide custom error handlers programmatically

["Yevhen Tsyba (JIRA)" <ji...@apache.org>]

Yevhen Tsyba created KAFKA-7522:
-----------------------------------

             Summary: As a client of kafka-streams library I want to provide custom error handlers programmatically
                 Key: KAFKA-7522
                 URL: https://issues.apache.org/jira/browse/KAFKA-7522
             Project: Kafka
          Issue Type: Improvement
          Components: streams
    Affects Versions: 1.1.0
            Reporter: Yevhen Tsyba


According to [KIP-210|https://cwiki.apache.org/confluence/display/KAFKA/KIP-210+-+Provide+for+custom+error+handling++when+Kafka+Streams+fails+to+produce] and [KIP-161|https://cwiki.apache.org/confluence/display/KAFKA/KIP-161%3A+streams+deserialization+exception+handlers], I can define custom error handlers via properties:
{code:java}
default.deserialization.exception.handler=org.apache.kafka.streams.errors
.LogAndContinueExceptionHandler

default.production.exception.handler=org.apache.kafka.streams.errors
.ProductionExceptionHandler

or 

settings.put(StreamsConfig.DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG,
            ProductionExceptionHandler.class);
{code}
Nevertheless, this solution has some limitations.

For example, I have a spring-based application, where my custom error handler is a bean. Then I want to add micrometer monitoring to my error handler.

The existed approach doesn't allow me to do it, because class creates outside of spring context. 

I think it would be better to have such a possibility to do so.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)