Function mz_coord::sink_connection::build_kafka
source · [−]async fn build_kafka(
builder: KafkaSinkConnectionBuilder,
id: GlobalId,
connection_context: ConnectionContext
) -> Result<SinkConnection, CoordError>