PULSAR_ACK_CHANNEL

risingwave_connector::source::pulsar::source::reader

Static PULSAR_ACK_CHANNEL 

Source 
pub static PULSAR_ACK_CHANNEL: LazyLock<Cache<String, UnboundedSender<Vec<u8>>>>