问在容器错误处理程序的情况下获取主题名称、分区和偏移量
EN

Stack Overflow用户

提问于 2019-02-12 20:49:55

回答 1查看 183关注 0票数 0

在使用Kafka主题的数据时，我得到了反序列化异常。我想将偏移量设置为当前+1，我有一个容器级别的错误处理程序，它接受异常、使用者记录和参数中的使用者对象。在异常消息中，我可以看到主题、分区和偏移量。但消费者记录为空。如何获得主题、分区和偏移量？

请帮帮忙。

回答已采纳

发布于 2019-02-12 21:36:41

错误发生在创建ConsumerRecord之前。

从版本2.2开始，您可以配置ErrorHandlingDeserializer2来包装真正的反序列化器；容器然后用DeserializationException调用错误处理程序，您将得到一个带有null值的ConsumerRecord。

异常在其byte[]属性中具有原始data。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54658494

复制

相似问题

问在容器错误处理程序的情况下获取主题名称、分区和偏移量EN