Function mz_storage_client::sink::build_kafka
source · async fn build_kafka(
builder: KafkaSinkConnectionBuilder,
connection_context: ConnectionContext
) -> Result<StorageSinkConnection, Error>async fn build_kafka(
builder: KafkaSinkConnectionBuilder,
connection_context: ConnectionContext
) -> Result<StorageSinkConnection, Error>