pub static SHARED_KAFKA_CLIENT: LazyLock<Cache<KafkaConnection, Weak<BaseConsumer<RwConsumerContext>>>>