1

アプリケーションの 1 つにnode-rdkafkaライブラリを使用しています。そのため、メッセージを生成する際に、 tenantIdをヘッダーと共に渡すという 1 つの要件があります。ドキュメントを確認しましたが、必要なものが得られなかったか、何か不足している可能性があります。node-rdkafka ライブラリでメッセージを生成する際に、ヘッダー付きのテナント ID を渡す方法はありますか?

4

1 に答える 1

0

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を参照してください

于 2019-12-13T10:55:13.030 に答える