Skip to main content

register_kafka_sink

Function register_kafka_sink 

Source
pub fn register_kafka_sink(
    registry: &ConnectorRegistry,
) -> Result<(), ConnectorError>
Expand description

Registers the Kafka sink connector with the given registry.

ยงErrors

Returns an error if a Kafka sink factory is already registered or the registry has been frozen.