【发布时间】：2018-04-04 04:38:41
【问题描述】：
spring-kafka版本1.1.x中的错误处理如何处理？
【问题讨论】：
标签： spring-kafka error-handling apache-kafka spring-kafka
【发布时间】：2018-04-04 04:38:41
【问题描述】：
在 1.x 中，您可以将 ErrorHandler 实现添加到侦听器容器（或容器工厂，如果您使用 @KafkaListener 注释）。
添加了 2.0 功能，以便在使用注释时为每个侦听器使用不同的错误处理程序时更容易配置。
【讨论】：
-
谢谢！将尝试实现这一点，你在 github 上有这样的文档吗？
-
在here 和the javadocs 中提到（简要）。
-
@GaryRussell 两个链接都已过期
-
如何在我的错误处理程序中获取消费者参考（或消费者数据）？我正在使用 Spring-kafka 1.3.2RELEASE。我需要为遇到错误的人手动提交偏移量。我知道如果我在 ErrorHandler 中有消费者引用，那么我可以提交它。所以我正在寻找在我的 ErrorHandler 中有消费者参考的方法。是否可以不更改 Spring-Kafka 版本？