我正在尝试开发/调试一个springkafka应用程序。我正在使用kafkatemplate将pojo序列化为json。但是，我无法记录实际的序列化json文本。有没有办法记录这些细节？需要什么日志配置？
zbq4xfa01#
这取决于您是如何进行序列化的。如果您使用的是 StringJsonMessageConverter 在模板中，使用 StringSerializer ，并使用 send(Message<?>) ，一个 ProducerInterceptor 在kafka属性中配置会看到json。如果您正在使用 JsonSerializer 它不会工作，因为拦截器在序列化之前看到记录。你必须自己创造 Serializer 那包裹着 JsonSerializer 并记录输出。
StringJsonMessageConverter
StringSerializer
send(Message<?>)
ProducerInterceptor
JsonSerializer
Serializer
1条答案
按热度按时间zbq4xfa01#
这取决于您是如何进行序列化的。如果您使用的是
StringJsonMessageConverter在模板中，使用StringSerializer，并使用send(Message<?>)，一个ProducerInterceptor在kafka属性中配置会看到json。如果您正在使用
JsonSerializer它不会工作，因为拦截器在序列化之前看到记录。你必须自己创造Serializer那包裹着JsonSerializer并记录输出。