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

Class TaskAssignmentUtils.RackAwareOptimizationParams

java.lang.Object

org.apache.kafka.streams.processor.assignment.TaskAssignmentUtils.RackAwareOptimizationParams

Enclosing class:

TaskAssignmentUtils

public static final class TaskAssignmentUtils.RackAwareOptimizationParams
extends Object

A simple config container for necessary parameters and optional overrides to apply when running the active or standby task rack-aware optimizations.

Method Summary

Modifier and Type	Method	Description
TaskAssignmentUtils.RackAwareOptimizationParams	forStatefulTasks()	Return a new config object with the tasksToOptimize set to all stateful tasks in the given ApplicationState
TaskAssignmentUtils.RackAwareOptimizationParams	forStatelessTasks()	Return a new config object with the tasksToOptimize set to all stateless tasks in the given ApplicationState
TaskAssignmentUtils.RackAwareOptimizationParams	forTasks(SortedSet<TaskId> tasksToOptimize)	Return a new config object with the provided tasksToOptimize
static TaskAssignmentUtils.RackAwareOptimizationParams	of(ApplicationState applicationState)	Return a new config object with no overrides and the tasksToOptimize initialized to the set of all tasks in the given ApplicationState
TaskAssignmentUtils.RackAwareOptimizationParams	withNonOverlapCostOverride(int nonOverlapCostOverride)	Return a new config object with the provided nonOverlapCost override applied
TaskAssignmentUtils.RackAwareOptimizationParams	withTrafficCostOverride(int trafficCostOverride)	Return a new config object with the provided trafficCost override applied

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

of

public static TaskAssignmentUtils.RackAwareOptimizationParams of(ApplicationState applicationState)

Return a new config object with no overrides and the tasksToOptimize initialized to the set of all tasks in the given ApplicationState

forStatefulTasks

public TaskAssignmentUtils.RackAwareOptimizationParams forStatefulTasks()

Return a new config object with the tasksToOptimize set to all stateful tasks in the given ApplicationState

forStatelessTasks

public TaskAssignmentUtils.RackAwareOptimizationParams forStatelessTasks()

Return a new config object with the tasksToOptimize set to all stateless tasks in the given ApplicationState

forTasks

public TaskAssignmentUtils.RackAwareOptimizationParams forTasks(SortedSet<TaskId> tasksToOptimize)

Return a new config object with the provided tasksToOptimize

withTrafficCostOverride

public TaskAssignmentUtils.RackAwareOptimizationParams withTrafficCostOverride(int trafficCostOverride)

Return a new config object with the provided trafficCost override applied

withNonOverlapCostOverride

public TaskAssignmentUtils.RackAwareOptimizationParams withNonOverlapCostOverride(int nonOverlapCostOverride)

Return a new config object with the provided nonOverlapCost override applied