我是新来Kafka和实现它在节点js。我用kafka js编写了一个consumer,希望从名为“topic-a”的主题的分区“0”中获取数据,该主题有3个分区-[0,1,2]。但是,我的消费者正在消费topic-a的所有分区。谁能告诉我怎么做吗?谢谢,这是预付款。这是我的密码-
const { Kafka } = require('kafkajs');
const kafka = new Kafka({
clientId: 'my-app',
brokers: ["localhost:9092"],
})
const consumer = kafka.consumer({ groupId: 'test-group' });
consumer.connect()
consumer.subscribe({ topic: 'topic-A', fromBeginning: true })
consumer.run({
eachMessage: async ({ topic, partition, message }) => {
},
})
我试着像下面这样明确地提到分区,但它不起作用-
consumer.subscribe({ topic: 'topic-A', partiton: 0, fromBeginning: true })
暂无答案!
目前还没有任何答案,快来回答吧!