Module config 

Kafka source connector configuration.

Provides KafkaSourceConfig for configuring the Kafka consumer, including broker connection, format, Schema Registry, backpressure, and pass-through rdkafka properties.

Structs

KafkaSourceConfig

Kafka source connector configuration.

SrAuth

Schema Registry authentication credentials.

Enums

AssignmentStrategy

Kafka partition assignment strategy.

CompatibilityLevel

Schema Registry compatibility level.

IsolationLevel

Consumer isolation level for reading transactional messages.

OffsetReset

Auto-offset reset policy for new consumer groups.

SaslMechanism

SASL authentication mechanism for Kafka.

SecurityProtocol

Kafka security protocol for broker connections.

StartupMode

Consumer startup mode controlling where to begin consuming.

TopicSubscription

Topic subscription mode: explicit list or regex pattern.