Table of Contents

Enum KafkaPartitionExecutionMode

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

Defines how a Kafka source is allowed to execute work across and within assigned partitions.

public enum KafkaPartitionExecutionMode

Fields

ParallelizeAcrossPartitions = 1

Allows different partitions to execute concurrently while preserving ordering within each partition.

PreservePartitionOrder = 0

Processes at most one record at a time per partition so partition ordering is preserved.

RelaxOrderingWithinPartition = 2

Allows multiple records from the same partition to execute concurrently, which can relax ordering guarantees.