kafka节点设置生产者选项

j2cgzkjk 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(290)

我不知道也许我太笨了，再也看不懂文档了。但我不知道如何为制片人设置选项。
您可以在这里找到的文档对于制作人来说是这样的：https://www.npmjs.com/package/kafka-node

const options = {
    requireAcks: 1,
    ackTiimeoutMs: 100,
    partitionerType: 2
}
const producer = new HighLevelProducer(client, options);

我真的不能为制片人设置其他选项吗？因为我可以在https://kafka.apache.org/documentation/ 很长。我想设置如下选项 enable.idempotence: true 给我的制作人。
谢谢你的帮助

apache-kafka JavaScript node.js

来源：https://stackoverflow.com/questions/52482538/kafka-node-setting-producer-options

1条答案

按热度按时间

6pp0gazn1#

试试这个：

const kafkaConf = {  
  "bootstrap.servers" : "localhost:9092",
  "key.serializer" : "org.apache.kafka.common.serialization.StringSerializer",
  "value.serializer" : "org.apache.kafka.common.serialization.StringSerializer",
  ...
  ...
  "enable.idempotence" : true,
  ...
};

const topic = <topic-name>;
const producer = new Kafka.Producer(kafkaConf);

注意：三个点{…}只是占位符，您可以在producer中添加更多属性。我刚选了一些基本的。
我希望这有帮助！

赞(0）回复(0）举报 2021-06-07

我来回答

kafka节点设置生产者选项

1条答案

相关问题

热门标签

最新问答