...
scheduled.rebalance.max.delay.ms
Type: Int32
Default: 300000 (5min)
This is a delay that the leader may set to tolerate departures of workers from the group by allowing a transient imbalance connector and task assignments. During this delay a worker has the opportunity to return to the group and get reassigned the same or similar amount of work as before. This property corresponds to the maximum delay that the leader may set in a single assignment. The actual delay used by the leader to hold off redistribution of connectors and tasks and maintain imbalance may be less or equal to this value.connect.protocol
Type: Enum
Values:eager
,compatible
Default: eagercompatible
This property defines which Connect protocol is enabled.eager
corresponds to the initial non-cooperative protocol that resolves imbalance with an immediate redistribution of connectors and tasks (version 0).compatible
corresponds to both eager (protocol version 0) and incremental cooperative (protocol version 1 or higher) protocols being enabled with the incremental cooperative protocol being preferred if both are supported (version 1 or version 0).
...
To downgrade your cluster to use protocol version 0 from version 1 or higher with
rebalancing policy what is required is to switch one of the workers back to eager
eager
mode.
Code Block | ||
---|---|---|
| ||
connect.protocol = eager |
Once this worker joins, the group will downgrade to protocol version 0 and eager
rebalancing policy, with immediately release of resources upon joining the group. This process will require a one-time double rebalancing, with the leader detecting the downgrade and first sending a downgraded assignment with empty assigned connectors and tasks and from then on just regular downgraded assignments.
...