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

Question

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

请帮忙。

Answer 1

错误发生在创建 ConsumerRecord 之前。

从 2.2 版开始，您可以配置 ErrorHandlingDeserializer2 来包装真正的解串器；然后容器使用 DeserializationException 调用错误处理程序，你将得到一个 ConsumerRecord 和 null 值。

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