使用KafkaJS创建主题时出错

Question

我正在使用KafkaJS创建主题。

 const kafka = new Kafka({

  connectionTimeout: 10_000,
  authenticationTimeout: 10_000,
  brokers: [`HOST_NAME:9092`],
  clientId: 'example-producer',
  ssl: {
    servername: 'HOST_NAME',
    rejectUnauthorized: false
  },
  sasl: {
    mechanism: 'plain',
    username: '*******',
    password: '******'
  }
})

const admin = kafka.admin();
await admin.connect()

const topic = 'test-topics';
const run = async () => {
  await admin.connect()
  await admin.createTopics({
    topics: [{ topic }],
    waitForLeaders: true,
  })
  await admin.createPartitions({
    topicPartitions: [{ topic: topic, count: 1}],
  })
}
run().catch(e => kafka.logger().error(`[Kafka-config] ${e.message}`, { stack: e.stack }));

出现以下错误：

message：“连接响应CreateTopics(键: 19，版本: 3)"，”代理“：”HOST_NAME:9092“，”clientId“：”示例-生产者“，”错误“：”请求参数不满足配置的策略“，"correlationId":3，”大小“：58}

但是，当我试图列出集群中的主题时，我得到了成功的响应，因为主题已经存在。

Answer 1

添加topics: [{ topic **,replicationFactor: 3**}]解决了这个问题