Hi,
I am using Kafka .9 and new Java consumer. I am polling inside a loop. I am
getting commitfailedexcption because of group rebalance, when code try to
execute consumer.commitSycn . Please note, I am adding session.timeout.ms
as 30000 and heartbeat.interval.ms as 10000 to consumer and polling happens
for sure with in 30000. Can anyone help me out. Please let me know if any
information is needed.
I am using 3 node kafka cluster.
Thanks,
Sunny

Reply via email to