On the same lines when will the owner column of the result produced by Consumer offset checker will be none?

and what will it signify? does it say that particualr partition is up for grab but no one has taken it? why will this happen?

I know i may be asking some silly questions but can some one please help me out here.

Thanks
Arjun Narasimha Kota

On Friday 11 April 2014 04:48 PM, Arjun wrote:
Some times, the error is even not printed. The blow line gets printed(i increased the number of retires to 10)

end rebalancing consumer group1_ip-10-122-57-66-1397214466042-81e47bfe try #9

and then the consumer just sits idle.

Thanks
Arjun Narasimha Kota

On Friday 11 April 2014 04:33 PM, Arjun wrote:
Once i get this exception

ERROR consumer.ZookeeperConsumerConnector: [xxxxxxxxxx ], error during syncedRebalance kafka.common.ConsumerRebalanceFailedException: xxxxxxxxx can't rebalance after 4 retries

The consumer is not consuming any more messages. Is this the behaviour? is there any property in high level consumer through which i can say to consumer to keep retrying, until consumer gets the data. This message is not atually being thrown in high level consumer. This is just logged in the logger. If the consumer will not get data after this exception, shouldn't this be thrown at a place user can catch it and raise an alert?


Thanks
Arjun Narasimha Kota


Reply via email to