Re: Kafka Consumers not rebalancing.

on, Jan 29, 2018 at 3:36 PM, satyajit vegesna <satyajit.ap...@gmail.com> 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 > w

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

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.

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.

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