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

Interface TaskAssignor

All Known Implementing Classes:

FallbackPriorTaskAssignor, HighAvailabilityTaskAssignor, StickyTaskAssignor

public interface TaskAssignor

Method Summary

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

Method Detail

assign

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

Returns:

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