java - 如何向 spring kafka 消息添加自定义 header 值？

Question

我是 springboot kafka 的新手，我在这篇文章之后创建了一个示例。

https://www.codenotfound.com/spring-kafka-boot-example.html

我目前使用的是 spring.kafka.version 1.1.6

我想向消息添加自定义 header ，以便我可以在 header 中发送某些属性，例如:fileName、fileId

我发现您可以将 kafka 元数据设置为 header ，但这不符合我的目的。

我有办法实现这个目标吗？如果可能的话，如果您能分享一个示例，我将不胜感激。

Answer 1

从版本1.3开始，Spring Kafka是基于Apache Kafka > 0.11 ，它引入了 header :https://issues.apache.org/jira/browse/KAFKA-4208 .

所以，现在您可以使用KafkaTemplate发送ProducerRecord与 headers已填充。

或者您可以发送 Message并依赖默认的 MessagingMessageConverter谁通过 KafkaHeaderMapper 将邮件头重新映射到记录.

请参阅引用手册中的更多信息:https://docs.spring.io/spring-kafka/docs/2.1.2.RELEASE/reference/html/_reference.html#headers