Re: How to assign all the partitions of a topic to consumer ?

Thanks Jason! It worked. I've missed it. On 17-Mar-2016 2:00 AM, "Jason Gustafson" wrote: > Have you looked at partitionsFor()? > > -Jason > > On Wed, Mar 16, 2016 at 4:58 AM, Kamal C wrote: > > > Hi, > > > > I'm using the new consumer in assign mode. I would like to assign all > > the par

How to assign all the partitions of a topic to consumer ?

Hi, I'm using the new consumer in assign mode. I would like to assign all the partitions of a topic to the consumer. For that, I need to know the number of partitions available in the topic. *consumer.assign(List partitions);* How to programmatically get the number of partitions in a topic?

Re: How to assign all the partitions of a topic to consumer ?

Have you looked at partitionsFor()? -Jason On Wed, Mar 16, 2016 at 4:58 AM, Kamal C wrote: > Hi, > > I'm using the new consumer in assign mode. I would like to assign all > the partitions of a topic to the consumer. > > For that, I need to know the number of partitions available in the topi