logging - 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 之外还有其他选择吗？

标签： loggingspring-kafka

Answer 1

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