TaskAssignor Contract

TaskAssignor is the abstraction of task assignors that can assign.

Table 1. TaskAssignor Contract
Method Description

assign

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

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

results matching ""

    No results matching ""