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