Hi,

Just wondering - is there any reason why rebalance.max.retries is 4 by
default? Is there any good reason why I shouldn't expect my consumers to
keep trying to rebalance for minutes (e.g. 30 retries every 6 seconds),
rather than seconds (4 retries every 2 seconds by default)?

Also, if my consumer fails to rebalance because of NoNodeException
(org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =
NoNode for /consumers/is-entity-modified-document-group/ids/<something>)
wouldn't that make sense to make Kafka restart it automatically once it
"uses" all the retries attempts? Or recreate the inexistent ZK node like, I
believe, it will happen on consumer restart?

I'm asking because that kind of errors seem to be "recoverable" ones, but -
if I understand it correctly - with current design they require
implementing additional mechanisms or manual intervention.


Kind regards,
MichaƂ

Reply via email to