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.
pub static SHARED_KAFKA_CONSUMER: LazyLock<Cache<KafkaConnectionProps, Weak<BaseConsumer<RwConsumerContext>>>>
Consumer client is shared, and the cache doesn’t manage the lifecycle, so we store Weak
and no eviction.