如何向spring kafka消息添加自定义头值？
我是springboot kafka的新手，我在这篇文章后面创建了一个例子。
https://www.codenotfound.com/spring-kafka-boot-example.html
我发现您可以将kafka元数据设置为标题，但这不符合我的目的。
我能做到这一点吗？如果可能的话，我很感激你能分享一个例子。
共有1个答案
从1.3版本开始，Spring Kafka基于Apache Kafka>0.11，它引入了header:https://issues.Apache.org/jira/browse/kafka-4208。
因此，现在可以使用KafKatemplate发送填充了标头的ProducerRecord。
也可以发送消息，并依赖于默认的MessagingMessageConverter，后者通过KafkaheaderMapper将消息的头重新映射到记录。
请参阅参考手册中的更多信息:https://docs.spring.io/spring-kafka/docs/2.1.2.release/Reference/html/_Reference.html#headers
-
问题内容： 我们有一个测试套件，主要使用带有Hamcrest匹配器的JUnit断言。我们的一个团队开始对AssertJ进行实验，并以其语法，灵活性和声明性给人留下了深刻的印象。JUnit提供的一项功能是我无法在AssertJ中找到与之等效的功能：添加自定义断言失败消息。 我们经常在比较不是为了人类可读性而制成的对象，这些对象将具有随机查找的Id或UUID，并且无法通过包含的数据来判断它们应该是什么
-
我们经常比较那些不是为了人类可读性而制作的对象，这些对象将具有随机的ID或UUID，并且不可能根据它们包含的数据来判断它们应该是什么。对于我们的代码库来说，这是一个不可避免的情况，可悲的是，它实现的目的之一是在其他服务之间映射数据，而不需要理解它是什么。 在JUnit中，方法提供的版本在参数之前带有参数。这使得添加一个简短的调试字符串变得微不足道，从而揭示了一些问题，比如比较对人类应该意味着什么。
-
我正在研究web服务。我想知道我们如何在JAX-WS类型的web服务中将头添加到SOAP请求中。 想想我的头球就像这样。 我的客户端类中有存根对象。我正在使用Apache Axis 2。所有的类都是自动生成的。 我想在客户端添加这个头信息。 编辑 正常类中的实际实现 私有静态最终字符串WS_URL=“http://localhost:9999/ws/hello？wsdl”； public stat
-
我正在使用具有非阻塞重试的SpringKafka2.8.0。我使用的是具有固定回退和死信主题的单个重试主题。这是我的配置： 我正在尝试实现失败标头管理，并将自定义标头添加到发送到 DLT 的邮件中： 它可以工作，但调用将禁用添加重试标头的标准机制：、 、
-
我的工具基本上读取PDF并在JTextArea中打印PDF的内容。在我的PDF包含阿拉伯语的PH Mirjan字体之前，一切正常。我的文本区域显示一些垃圾字符，如下所示。 我该如何解决这个问题？ 我的文本区域的默认字体是Arial Unicode MS。我可以配置文本区域的字体吗？假设我在本地下载了PH Mirjan，如何将文本区域字体更改为下载的字体。非常感谢任何建议或参考链接。 编辑 这给了我
-
我想添加“from”（date）来响应datepicker输入，但到目前为止，我有一些奇怪的行为。 我的代码： 到目前为止，我试过： 和 但这两种解决方案都将我的日期从“2020年9月14日16:43”转变为“从周一9月14 2020 17:19:38格林尼治标准时间0400（留尼汪岛）”，这是不必要的行为，因为我绝对想要法语日期。任何想法？谢啦