I have 6 partitions and 3 consumers. I need to assign partition1 and partition2 to consumer1, partition3 and partition5 to consumer2, partition4 and partition6 to the consumer3. I tried with assign() function, but it's not giving the expected result. I am using confluent kafka with node-rdkafka library.
I have 6 partitions and 3 consumers. I need to assign partition1 and partition2 to consumer1, partition3 and partition5 to consumer2, partition4 and partition6 to the consumer3. I tried with assign() function, but it's not giving the expected result. I am using confluent kafka with node-rdkafka library.