Using multiple partitions in Consumer

[clivedsouza1010]

• Check the Troubleshooting / FAQ ?
• Search the issues ?

Bug Report

Hi,

I have a topic with multiple partitions. I am trying to create a Consumer but not able to specify all partitions while creating it, for,eg,

const consumer = new Consumer(kafkaClient, [{ topic: consumeTopic }], { groupId: 'kafka-node-group', autoCommit: false });

the above code just reads from partition 0. I tried something like,

const consumer = new Consumer(kafkaClient, [{ topic: consumeTopic, partition: '*' }], { groupId: 'kafka-node-group', autoCommit: false }); but, it did not work.

Can someone help me out. Thanks

Environment

• Node version: 10.15.3
• Kafka-node version: 5.0.0
• Kafka version:

For specific cases also provide

• Number of Brokers: 4
• Number partitions for topic: 60

Include Sample Code to reproduce behavior

// include code here

Include output with Debug turned on

Thanks for your contribution!

[0807Jpatel]

Using ConsumerGroup lets you fetch data from all the partitions.