如何使用kafkajs库使用kafka主题的特定分区

t98cgbkg  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(272)

我是新来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 })

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题