Module config 

Kafka source config — 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.

SchemaEvolutionStrategy

Strategy for handling Avro schema evolution at runtime.

SecurityProtocol

Kafka security protocol for broker connections.

StartupMode

Consumer startup mode controlling where to begin consuming.

SubjectNameStrategy

Confluent subject-name strategy.

TopicSubscription

Topic subscription mode: explicit list or regex pattern.