Table of Contents

Enum KafkaPartitionRebalanceMode

Namespace
Pipelinez.Kafka.Configuration
Assembly
Pipelinez.Kafka.dll

Defines how a Kafka source should behave when a partition rebalance revokes owned partitions.

public enum KafkaPartitionRebalanceMode

Fields

DrainAndYield = 0

Stops admitting new work for the partition and waits for in-flight records to drain before yielding ownership.

StopAcceptingNewWorkAndYield = 1

Stops admitting new work immediately and yields ownership as soon as active work is no longer accepted.