Package org.apache.kafka.streams.processor.assignment
package org.apache.kafka.streams.processor.assignment
Provides classes and interfaces used to manage and assign tasks within Kafka Streams applications.
-
ClassDescriptionA read-only metadata class representing the state of the application and the current rebalance.Assignment related configs for the Kafka Streams
TaskAssignor.A simple container class for the assignor to return the desired placement of active and standby tasks on KafkaStreams clients.A read-only metadata class representing the current state of each KafkaStreams client with at least one StreamThread participating in this rebalanceA simple wrapper around UUID that abstracts a Process IDA set of utilities to help implement task assignment via theTaskAssignorA simple config container for necessary parameters and optional overrides to apply when running the active or standby task rack-aware optimizations.A TaskAssignor is responsible for creating a TaskAssignment from a givenApplicationState.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 assignedWrapper class for the final assignment of active and standbys tasks to individual KafkaStreams clients.A simple container class corresponding to a givenTaskId.This is a simple container class used during the assignment process to distinguish TopicPartitions type.