Skip to main content

PULSAR_ACK_CHANNEL

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

Static PULSAR_ACK_CHANNEL 

Source 
pub(crate) static PULSAR_ACK_CHANNEL: LazyLock<Mutex<HashMap<String, UnboundedSender<Vec<u8>>>>>