risingwave_connector::source::kafka::enumerator

Function build_kafka_admin

Source 
async fn build_kafka_admin(
    config: &ClientConfig,
    properties: &KafkaProperties,
) -> ConnectorResult<AdminClient<RwConsumerContext>>