我正在尝试开发/调试Spring KAfka应用程序 . 我正在使用KafkaTemplate将POJO序列化为JSON . 但是我无法记录实际的序列化JSON文本 . 有没有办法记录这些细节？需要什么日志配置？
这取决于您如何进行序列化 . 如果在模板中使用 StringJsonMessageConverter ，使用 StringSerializer ，并使用 send(Message<?>) ，则在Kafka属性中配置的 ProducerInterceptor 将看到JSON .
StringJsonMessageConverter
StringSerializer
send(Message<?>)
ProducerInterceptor
如果您使用 JsonSerializer 它将无法工作，因为拦截器在序列化之前看到记录 . 你必须创建自己的包含 JsonSerializer 的 Serializer 并记录输出 .
JsonSerializer
Serializer
1 回答
这取决于您如何进行序列化 . 如果在模板中使用
StringJsonMessageConverter，使用StringSerializer，并使用send(Message<?>)，则在Kafka属性中配置的ProducerInterceptor将看到JSON .如果您使用
JsonSerializer它将无法工作，因为拦截器在序列化之前看到记录 . 你必须创建自己的包含JsonSerializer的Serializer并记录输出 .