Page History

package org.apache.kafka.streams.processor.assignment; 

/**
 * A simple interface for the assignor to return the desired placement of active and standby tasks on Streams client nodes 
 */
public interface StreamsClientAssignment {
  ProcessID processId();

  long followupRebalanceDeadline();

  Map<TaskId, AssignedTask> assignment();

  /**
   * @return the actual deadline in objective time, using ms since the epoch, after which the
   * followup rebalance will be attempted.
   * Equivalent to {@code 'now + followupRebalanceDelay'}
   */
  longInstant followupRebalanceDeadline();

  static class AssignedTask {
    public final boolean isActive;
    public final boolean isStateful;
  }
}