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

Question

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

As I see it was introduced in version 2.0...

Answer 1

在 1.x 中，您可以将 ErrorHandler 实现添加到侦听器容器（或容器工厂，如果您使用 @KafkaListener 注释）。

如果您希望在使用注释时为每个侦听器使用不同的错误处理程序，则添加 2.0 功能可以更轻松地进行配置。