我对springboot kafka是个新手，我在这篇文章后面创建了一个例子。
https://www.codenotfound.com/spring-kafka-boot-example.html
我目前正在使用spring.kafka.version 1.1.6
我想在消息中添加自定义头，这样我就可以在头中发送某些属性，例如：filename，fileid
我发现你可以将kafka元数据设置为头，这不符合我的目的。
我能做到这一点吗？如果可能的话，我很感激你能举个例子。
我对springboot kafka是个新手，我在这篇文章后面创建了一个例子。
https://www.codenotfound.com/spring-kafka-boot-example.html
我目前正在使用spring.kafka.version 1.1.6
我想在消息中添加自定义头，这样我就可以在头中发送某些属性，例如：filename，fileid
我发现你可以将kafka元数据设置为头，这不符合我的目的。
我能做到这一点吗？如果可能的话，我很感激你能举个例子。
1条答案
按热度按时间s4chpxco1#
从版本开始
1.3，spring kafka基于apache kafka>0.11，它引入了标题：https://issues.apache.org/jira/browse/kafka-4208.所以，现在你可以用
KafkaTemplate发送ProducerRecord与headers密集的。或者你可以发一封信
Message依赖于违约MessagingMessageConverter谁通过将邮件头重新Map到记录KafkaHeaderMapper.请参阅参考手册中的更多信息：https://docs.spring.io/spring-kafka/docs/2.1.2.release/reference/html/_reference.html#headers