risingwave_connector::source::kafka::enumerator

Static SHARED_KAFKA_ADMIN

source
pub static SHARED_KAFKA_ADMIN: LazyLock<Cache<KafkaConnectionProps, Arc<AdminClient<RwConsumerContext>>>>
Expand description

Admin client is short-lived, so we store Arc and sets a time-to-idle eviction policy.