node.js - kafka-node 我可以使用配置retention.ms 创建主题吗

Question

我在编码中遇到使用Kafka-node V1.3在nodejs中创建主题的情况，但是创建的主题应该有自定义retention.ms参数，我不想使用代理配置retention.ms，因为它适用于所有话题。

提前致谢。

Answer 1

根据文档，似乎有可能

var kafka = require('kafka-node');
var client = new kafka.KafkaClient();

var topicsToCreate = [{
  topic: 'foo',
  partitions: 5,
  replicationFactor: 3,
  // Optional set of config entries
  configEntries: [
    {
      name: 'retention.ms',
      value: '1000000'
    }
  ]
}];

client.createTopics(topicsToCreate, (error, result) => {
  // result is an array of any errors if a given topic could not be created
});