Skip to main content

register_kafka_sink

Function register_kafka_sink 

Source
pub fn register_kafka_sink(registry: &ConnectorRegistry)
Expand description

Registers the Kafka sink connector with the given registry.

After registration, the runtime can instantiate KafkaSink by name when processing CREATE SINK ... WITH (connector = 'kafka').