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()方法即可。