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

Question

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

Answer 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