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

Question

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

Answer 1

node-rdkafka 2.7 中添加了对消息 header 的支持.

例如:

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