risingwave_
connector
2.7.0-alpha
Module enumerator
Module Items
Structs
Statics
In risingwave_
connector::
source::
mqtt
risingwave_connector
::
source
::
mqtt
Module
enumerator
Copy item path
Source
Structs
§
Mqtt
Connection
Check
🔒
Mqtt
Split
Enumerator
Statics
§
SHARED_
MQTT_
CLIENT
🔒
Consumer client is shared, and the cache doesn’t manage the lifecycle, so we store
Weak
and no eviction.