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

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: streams
• Labels: needs-kip
• Assignee: Unassigned
• Reporter: Yevhen Tsyba
• Created: 19/Oct/18 13:36
• Updated: 19/Oct/18 16:49

Description

According to KIP-210 and KIP-161, I can define custom error handlers via properties:

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

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.