Function coord::sink_connector::build_kafka [−][src]
async fn build_kafka(
builder: KafkaSinkConnectorBuilder,
id: GlobalId
) -> Result<SinkConnector, CoordError>async fn build_kafka(
builder: KafkaSinkConnectorBuilder,
id: GlobalId
) -> Result<SinkConnector, CoordError>