...
The primary change here will be introducing a new public config for the active task assignor class. Note that the standby task assignor thread-level assignment will remain an internal implementation detail
| Code Block | ||||
|---|---|---|---|---|
| ||||
/** {@code probingtask.rebalanceassignor.interval.msclass} */
public static final String ACTIVE_TASK_ASSIGNOR_CLASS_CONFIG = "active.task.assignor.class";
private static final String ACTIVE_TASK_ASSIGNOR_CLASS_DOC = "A task assignor class or class name implementing the <@link TaskAssignor> interface"
+ " that will be used to assign active tasks to client nodes during a rebalance. Note that tasks will be distributed equally among the"
+ "StreamThreads within each client with maximal stickiness ie returning as many tasks as possible to their previous owner on that"
+ "client node. Defaults to the <@link HighAvailabilityTaskAssignor> class."; |
We will also remove the old internal config (which we can do without deprecation as this was an internal config and thus by definition not part of the public API
...