如何在 Java Spring 中记录原始 Kafka 消息以及分区和偏移量？

Question

当我的应用程序使用 Kafka 消息时，我希望有一个日志行来捕获原始 Kafka 消息正文（在我的例子中为 JSON）以及消息的主题、分区和偏移量。 我尝试实现

RecordInterceptor

，但在

Deserializer

处理原始消息之前，它似乎无法访问原始消息，并且

Deserializer

无法访问分区或偏移量。显然，如果我有一个包含主题、分区和偏移量的日志，我可以在事后查找原始消息，但将所有四个消息放在一个处理位置会更方便。

Answer 1

ConsumerRecord

有您需要的东西。反序列化器只接受主题名称内容字节和记录头；它不需要偏移量或分区元数据。