GitHub user leonhong opened a pull request:
https://github.com/apache/kafka/pull/4302
when broker is unavailable, fast revover
- when broker is unavailable(such as broker's machine is down), controller
will wait 30 sec timeout by dedault. it seems to be that the timeout waiti
GitHub user leonhong opened a pull request:
https://github.com/apache/kafka/pull/4290
Auto-commit of offsets fail, and not recover forever...
* Auto-commit of offsets fail, and not recover **forever**. at
sendOffsetCommitRequest, while "generation equal NULL", ConsumerC