Spring Kafka监听器方法-记录输入记录

Question

我使用的是spring-kafka，我的@KafkaListener方法有一个用@org.springframework.messaging.handler.annotation.Payload注释的参数，如下所示：

@KafkaListener(topics = "my-topic")
public void consumeTrigger(@Payload InputDTO InputDTO) {
   ...
}

输入是json格式的，我使用org.springframework.kafka.support.serializer.JsonDeserializer作为值反序列化器。一切都很好，但我需要记录接收到的输入json。有没有spring-kafka这样的工具?如果没有，除了提供定制的JsonDeserializer之外，还有没有其他选择？

Answer 1

目前在反序列化程序中没有日志记录；您可以简单地将JsonDeserializer包装在自己的中，并在日志记录后调用它的deserialize()；只需确保也委托configure()方法即可。