Class FallbackPriorTaskAssignor

  • All Implemented Interfaces:
    TaskAssignor

    public class FallbackPriorTaskAssignor
    extends java.lang.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 Detail

      • FallbackPriorTaskAssignor

        public FallbackPriorTaskAssignor()