...
Each member encodes the lag of its standby tasks in its metadata. We can not update the lag in every heartbeat request because that would constantly trigger reassignment in the group. Instead, when a) the task lag has been reduced within the acceptable.recovery.lag threshold or b) the task lag is consistently increasing for some time, the member should consider triggering a rebalance by sending its next heartbeat with the appropriate encoded reason and the updated task lags.
Upgrade Path
TODO
Public Interfaces
This section lists the changes impacting the public interfaces.
...
Code Block | ||||
---|---|---|---|---|
| ||||
Response Handling
TODO
...
Records
Broker Configurations
Group Configurations
Consumer API
Consumer Configurations
Streams Metadata
Streams Configurations
Admin API
kafka-consumer-groups
...
Compatibility, Deprecation, and Migration Plan
...