Skip to main content

Module sink_config

Module sink_config 

Source
Expand description

Kafka sink connector configuration.

KafkaSinkConfig encapsulates all tuning knobs for the Kafka producer, parsed from a SQL WITH (...) clause via ConnectorConfig.

Structs§

KafkaSinkConfig
Configuration for the Kafka Sink Connector.

Enums§

CompressionType
Compression type for produced Kafka messages.
PartitionStrategy
Partitioning strategy for distributing records across Kafka partitions.
SinkEnvelope
How the sink encodes an updating (changelog) input to Kafka.