risingwave_connector::sink::pulsar

Function pulsar_to_sink_err

source 
fn pulsar_to_sink_err(e: Error) -> SinkError