Spring Kafka error handling - v1.1.x

apache-kafka, error-handling, spring-kafka

Solution

In 1.x you can add an `ErrorHandler` implementation to the listener container (or container factory if you are using `@KafkaListener` annotations).

The 2.0 feature was added to make it easier to configure if you want a different error handler for each listener when using annotations.

Problem

How to deal with error handling in spring-kafka version `1.1.x`? As I see it was introduced in version `2.0`...

Original source