有没有一种方法可以在使用 node-rdkafka 库生成消息时传递带有 header 的tenantId？答案

【问题标题】：Is there a way we can pass tenantId with header while producing the messages with node-rdkafka library?有没有一种方法可以在使用 node-rdkafka 库生成消息时传递带有 header 的tenantId？
【发布时间】：2019-12-13 06:00:30
【问题描述】：

我正在为我的一个应用程序使用 node-rdkafka 库。所以我有一个要求是在生成消息时将 tenantId 与 header 一起传递。我检查了文档，但没有得到我需要的东西，或者我可能遗漏了一些东西。那么有没有一种方法可以在使用 node-rdkafka 库生成消息时传递带有 headers 的tenantid？

【问题讨论】：

为什么不能在消息键或值中包含它？
@cricket_007 是的，我们可以将标头数据与消息一起发送，但是标头为请求添加了一些特定目的，因此只想发送标头数据与标头。

标签： javascript node.js apache-kafka librdkafka

【解决方案1】：

node-rdkafka 2.7 中添加了对消息头的支持。

例如：

var headers = [
  { header: "header value" }
]
producer.produce(topicName, partition, value, key, Date.now(), "", headers);

见https://github.com/Blizzard/node-rdkafka/blob/master/examples/producer.md

【讨论】：

这就是我想要的。让我执行此操作，然后将接受您的回答。谢谢