Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • 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 will leader may set in a single assignment. The actual delay used by the Leader can 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, cooperative
    Default: eager
    This property defines which Connect protocol is enabled.
    • eager corresponds to current functionality the initial non-cooperative protocol that resolves imbalance with an immediate redistribution of connectors and tasks (version 0). 
    • compatible corresponds to both protocols eager and cooperative protocols being enabled with Incremental Cooperative Connect the incremental cooperative protocol being preferred if both are supported (version 1 or version 0).
    • cooperative means that only Incremental Cooperative Connect an incremental cooperative protocol is enabled that tolerates imbalances in connectors and tasks to a certain maximum delay (version 1 or higher).

Compatibility, Deprecation, and Migration Plan

...