[
https://issues.apache.org/jira/browse/KAFKA-19829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
travis updated KAFKA-19829:
---------------------------
Description:
During testing, an artifact of the new rebalance protocol showed up. In some
cases, the first joining member gets all active tasks assigned, and is slow to
revoke the tasks after more member has joined the group. This affects in
particular cases where the first member is slow (possibly overloaded in the
case of cloudlimits benchmarks) and there are a lot of tasks to be assigned.
To help with this situation, we want to introduce a new group-specific
configuration to delay the initial rebalance.
was:
During cloudlimits testing, an artifact of the new rebalance protocol showed
up. In some cases, the first joining member gets all active tasks assigned, and
is slow to revoke the tasks after more member has joined the group. This
affects in particular cases where the first member is slow (possibly overloaded
in the case of cloudlimits benchmarks) and there are a lot of tasks to be
assigned.
To help with this situation, we want to introduce a new group-specific
configuration to delay the initial rebalance.
> Implement group-level initial rebalance delay
> ---------------------------------------------
>
> Key: KAFKA-19829
> URL: https://issues.apache.org/jira/browse/KAFKA-19829
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 4.2.0
> Reporter: travis
> Assignee: travis
> Priority: Major
> Fix For: 4.2.0
>
>
> During testing, an artifact of the new rebalance protocol showed up. In some
> cases, the first joining member gets all active tasks assigned, and is slow
> to revoke the tasks after more member has joined the group. This affects in
> particular cases where the first member is slow (possibly overloaded in the
> case of cloudlimits benchmarks) and there are a lot of tasks to be assigned.
> To help with this situation, we want to introduce a new group-specific
> configuration to delay the initial rebalance.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
