Re: Kafka Consumers not rebalancing.

atyajit. On Mon, Jan 29, 2018 at 3:36 PM, satyajit vegesna wrote: > Hi All, > > I was experimenting on the new consumer API and have a question regarding > the rebalance process. > > I start a consumer group with single thread and make the Thread sleep > while p

Kafka Consumers not rebalancing.

Hi All, I was experimenting on the new consumer API and have a question regarding the rebalance process. I start a consumer group with single thread and make the Thread sleep while processing the records retrieved from the first consumer.poll call, i was making sure the Thread.sleep time goes bey

ZkUtils.getAllPartitions giving more partition counts.

Hi, Would like to understand the purpose of ZkUtils.getAllPartitions, as when i try to use the method, i end up getting wrong number of partitions assigned to Topics, i am not really sure if my understanding is wrong about this method. i have assumed this method would return the partition count. B

Build error using intellij.

Hi, I am trying to build kafka from source code, but i get below error when i try to build the project.(Have use gradle .idea command) and when i try to click on the import statements, they end up opening in test folder of client package and not main package. Any help would be appreciated. /User

Way to check if custom SMT has been added to the classpath or even if it i working.

Hi All, i have created a custom SMT and have deployed. I would like to know if there is a way to check if the transform is working or not.(def not working as the messages are not getting transformed) I am also trying to remote debug using intellij and nothing seam working, as i do not see any con