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

Question

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

Answer 1

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

例如：

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

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

Is there a way we can pass tenantId with header while producing the messages with node-rdkafka library?

javascript

node.js

apache-kafka

librdkafka