risingwave_connector::sink::pulsar

Function pulsar_to_sink_err

Source 
fn pulsar_to_sink_err(e: Error) -> SinkError