Namespace Org.Apache.Kafka.Streams.Processor.Assignment

Classes

ApplicationState

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/ApplicationState.html

AssignmentConfigs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.html

KafkaStreamsAssignment

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/KafkaStreamsAssignment.html

KafkaStreamsState

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/KafkaStreamsState.html

ProcessId

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/ProcessId.html

TaskAssignmentUtils

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.html

TaskAssignmentUtils.MoveStandbyTaskPredicate

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.MoveStandbyTaskPredicate.html

TaskAssignmentUtils.RackAwareOptimizationParams

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.RackAwareOptimizationParams.html

TaskAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignor.html

TaskAssignor.AssignmentError

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignor.AssignmentError.html

TaskAssignor.TaskAssignment

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskAssignor.TaskAssignment.html

TaskInfo

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskInfo.html

TaskTopicPartition

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/assignment/TaskTopicPartition.html

Interfaces

IApplicationState

.NET interface for TO BE DEFINED FROM USER

IKafkaStreamsState

.NET interface for TO BE DEFINED FROM USER

ITaskAssignor

.NET interface for TO BE DEFINED FROM USER

ITaskInfo

.NET interface for TO BE DEFINED FROM USER

ITaskTopicPartition

.NET interface for TO BE DEFINED FROM USER