使用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 }));

获取以下错误：

消息"："[连接]响应创建主题(密钥：19、版本：3("经纪人"："HOST_NAME:9092"clientId"："示例生产者"错误"："请求参数不满足配置的策略"correlationId"：3；尺寸"：58｝

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

Answer 1

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