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

Class FallbackPriorTaskAssignor

java.lang.Object

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

All Implemented Interfaces:

TaskAssignor

public class FallbackPriorTaskAssignor
extends Object
implements TaskAssignor

A special task assignor implementation to be used as a fallback in case the configured assignor couldn't be invoked. Specifically, this assignor must: 1. ignore the task lags in the ClientState map 2. always return true, indicating that a follow-up rebalance is needed

Constructor Summary

Constructors

Constructor	Description
FallbackPriorTaskAssignor()

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

FallbackPriorTaskAssignor

public FallbackPriorTaskAssignor()

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