Function mz_coord::sink_connector::build_kafka
source · [−]async fn build_kafka(
builder: KafkaSinkConnectorBuilder,
id: GlobalId,
connector_context: ConnectorContext
) -> Result<SinkConnector, CoordError>