Spring Kafka错误处理-v1.1.x

问题描述:

如何处理 spring -kafka 版本 1.1.x

我看到它是在 2.0版本中引入的/ code> ...

在1.x版本中,您可以添加 ErrorHandler 实现到侦听器容器(如果使用 @KafkaListener 注释,则为容器工厂)。

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

添加了2.0功能,以便在使用批注时为每个侦听器使用不同的错误处理程序,从而使配置更加容易。

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.