Class KafkaSourceOptions

Configuration block for a Kafka Source

public class KafkaSourceOptions : KafkaOptions

Inherited Members: KafkaOptions.BootstrapServers

KafkaOptions.BootstrapUser

KafkaOptions.BootstrapPassword

KafkaOptions.SecurityProtocol

KafkaOptions.SaslMechanism

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Gets or sets the automatic offset commit interval in milliseconds when broker auto-commit is enabled.

public int? AutoCommitIntervalMs { get; set; }

Gets or sets the Kafka consumer group used by the source.

public string ConsumerGroup { get; set; }

Gets or sets partition-aware scaling options for distributed Kafka consumption.

public KafkaPartitionScalingOptions PartitionScaling { get; set; }

Gets or sets optional schema registry configuration used by Kafka deserializers.

public KafkaSchemaRegistryOptions Schema { get; set; }

Gets or sets a value indicating whether a brand new consumer group should begin from the start of the topic.

public bool StartOffsetFromBeginning { get; set; }

Gets or sets the Kafka topic to consume from.

public string TopicName { get; set; }