build_pulsar_ack_channel_id

risingwave_connector::source

Function build_pulsar_ack_channel_id 

Source 
pub fn build_pulsar_ack_channel_id(
    source_id: SourceId,
    split_id: &SplitId,
) -> String