Spring Kafka Producer 日志记录

Question

我正在尝试开发/调试 Spring KAfka 应用程序。我正在使用 KafkaTemplate 将 POJO 序列化为 JSON。但是我无法记录实际的序列化 JSON 文本。有没有办法记录这些详细信息？需要什么日志配置？

Answer 1

这取决于您如何进行序列化。如果您在模板中使用StringJsonMessageConverter，使用StringSerializer，并使用send(Message<?>)，则在Kafka 属性中配置的ProducerInterceptor 将看到JSON。

如果您使用的是JsonSerializer，它将不起作用，因为拦截器在序列化之前会看到记录。您必须创建自己的 Serializer 来包装 JsonSerializer 并记录输出。