TaskAssignor Contract

TaskAssignor is the abstraction of task assignors that can assign.

Table 1. TaskAssignor Contract
Method Description


void assign(int numStandbyReplicas)

Assigns tasks to clients with a given number of standby replicas

Used exclusively when StreamsPartitionAssignor is requested to perform group assignment

StickyTaskAssignor is the one and only known implementation of the TaskAssignor Contract.

results matching ""

    No results matching ""