Interface | Description |
---|---|
ApplicationState |
A read-only metadata class representing the state of the application and the current rebalance.
|
KafkaStreamsState |
A read-only metadata class representing the current state of each KafkaStreams client with at least one StreamThread participating in this rebalance
|
TaskAssignmentUtils.MoveStandbyTaskPredicate | |
TaskAssignor |
A TaskAssignor is responsible for creating a TaskAssignment from a given
ApplicationState . |
TaskInfo |
A simple container class corresponding to a given
TaskId . |
TaskTopicPartition |
This is a simple container class used during the assignment process to distinguish
TopicPartitions type.
|
Class | Description |
---|---|
AssignmentConfigs |
Assignment related configs for the Kafka Streams
TaskAssignor . |
KafkaStreamsAssignment |
A simple container class for the assignor to return the desired placement of active and standby tasks on
KafkaStreams clients.
|
KafkaStreamsAssignment.AssignedTask | |
ProcessId |
A simple wrapper around UUID that abstracts a Process ID
|
TaskAssignmentUtils |
A set of utilities to help implement task assignment via the
TaskAssignor |
TaskAssignmentUtils.RackAwareOptimizationParams |
A simple config container for necessary parameters and optional overrides to apply when
running the active or standby task rack-aware optimizations.
|
TaskAssignor.TaskAssignment |
Wrapper class for the final assignment of active and standbys tasks to individual
KafkaStreams clients.
|
Enum | Description |
---|---|
KafkaStreamsAssignment.AssignedTask.Type | |
TaskAssignor.AssignmentError |
NONE: no error detected
ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES: multiple KafkaStreams clients assigned with the same active task
INVALID_STANDBY_TASK: stateless task assigned as a standby task
MISSING_PROCESS_ID: ProcessId present in the input ApplicationState was not present in the output TaskAssignment
UNKNOWN_PROCESS_ID: unrecognized ProcessId not matching any of the participating consumers
UNKNOWN_TASK_ID: unrecognized TaskId not matching any of the tasks to be assigned
|