Benn
Results
2
issues of
Benn
Description =========== When I set "group.initial.rebalance.delay.ms=10000" on broker version "3.1.0", the messages polled by method `consumer.poll(timeout=1.0)` sometimes with from very high number offset() (such as 4272995135), even though the maximum...
wait info
Producer meet NotLeaderForPartitionException when a partition moved to new broker on auto rebalance
3
I've run a producer online for a while which keep sending messages to kafka. But time to time I got this exception "NotLeaderForPartitionException". And I checked broker logs, Somehow the...