Thanks Jason! It worked. I've missed it.
On 17-Mar-2016 2:00 AM, "Jason Gustafson" <ja...@confluent.io> wrote: > Have you looked at partitionsFor()? > > -Jason > > On Wed, Mar 16, 2016 at 4:58 AM, Kamal C <kamaltar...@gmail.com> 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 topic. > > > > *consumer.assign(List<TopicPartitions> partitions);* > > > > How to programmatically get the number of partitions in a topic? > > > > --Kamal > > >
