risingwave_connector::source::kafka::enumerator

Static SHARED_KAFKA_CONSUMER

source
pub static SHARED_KAFKA_CONSUMER: LazyLock<Cache<KafkaConnectionProps, Weak<BaseConsumer<RwConsumerContext>>>>
Expand description

Consumer client is shared, and the cache doesn’t manage the lifecycle, so we store Weak and no eviction.