java.lang.Object
org.apache.kafka.streams.processor.assignment.assignors.StickyTaskAssignor
All Implemented Interfaces:
Configurable, TaskAssignor

public class StickyTaskAssignor extends Object implements TaskAssignor
  • Field Details

    • DEFAULT_STICKY_TRAFFIC_COST

      public static final int DEFAULT_STICKY_TRAFFIC_COST
      See Also:
    • DEFAULT_STICKY_NON_OVERLAP_COST

      public static final int DEFAULT_STICKY_NON_OVERLAP_COST
      See Also:
  • Constructor Details

    • StickyTaskAssignor

      public StickyTaskAssignor()
    • StickyTaskAssignor

      public StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment)
  • Method Details