Class KafkaPartitionScalingOptions

Namespace

Pipelinez.Kafka.Configuration

Assembly

Pipelinez.Kafka.dll

Configures partition-aware scheduling and rebalance behavior for Kafka sources.

public sealed class KafkaPartitionScalingOptions

Inheritance

object

KafkaPartitionScalingOptions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

EmitPartitionExecutionEvents

Gets or sets a value indicating whether partition execution lifecycle events should be raised.

public bool EmitPartitionExecutionEvents { get; init; }

Property Value

bool

ExecutionMode

Gets or sets how records may execute across and within assigned partitions.

public KafkaPartitionExecutionMode ExecutionMode { get; init; }

Property Value

KafkaPartitionExecutionMode

MaxConcurrentPartitions

Gets or sets the maximum number of partitions that may have active in-flight work at one time.

public int MaxConcurrentPartitions { get; init; }

Property Value

int

MaxInFlightPerPartition

Gets or sets the maximum number of in-flight records allowed within a single partition.

public int MaxInFlightPerPartition { get; init; }

Property Value

int

RebalanceMode

Gets or sets how partition revocation should be coordinated during rebalances.

public KafkaPartitionRebalanceMode RebalanceMode { get; init; }

Property Value

KafkaPartitionRebalanceMode

Methods

Validate()

Validates the configured scaling options and returns the same instance when they are valid.

public KafkaPartitionScalingOptions Validate()

Returns

KafkaPartitionScalingOptions

The validated options instance.

Exceptions

InvalidOperationException

Thrown when the execution mode requires ordered partition processing but MaxInFlightPerPartition allows more than one record.