Package org.apache.kafka.streams.processor.internals.assignment

Class HighAvailabilityTaskAssignor

java.lang.Object

org.apache.kafka.streams.processor.internals.assignment.HighAvailabilityTaskAssignor

All Implemented Interfaces:

TaskAssignor

public class HighAvailabilityTaskAssignor
extends Object
implements TaskAssignor

Constructor Summary

Constructors

Constructor	Description
HighAvailabilityTaskAssignor()

Method Summary

Modifier and Type	Method	Description
boolean	assign(Map<UUID,ClientState> clients, Set<TaskId> allTaskIds, Set<TaskId> statefulTaskIds, AssignorConfiguration.AssignmentConfigs configs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HighAvailabilityTaskAssignor

public HighAvailabilityTaskAssignor()

Method Detail

assign

public boolean assign(Map<UUID,ClientState> clients,
                      Set<TaskId> allTaskIds,
                      Set<TaskId> statefulTaskIds,
                      AssignorConfiguration.AssignmentConfigs configs)

Specified by:

assign in interface TaskAssignor

Returns:

whether the generated assignment requires a followup probing rebalance to satisfy all conditions