anirudh-simha

Even we are trying the same thing with building a new consumer for each partition.If my topic has 4 partitions, we initialize 4 consumers and leave the assignment of partitions...