risingwave_connector::sink::pulsar

Function build_pulsar_producer

source 
async fn build_pulsar_producer(
    pulsar: &Pulsar<TokioExecutor>,
    config: &PulsarConfig,
) -> Result<Producer<TokioExecutor>>