risingwave_connector::source::kafka::enumerator

Function build_kafka_client

Source 
async fn build_kafka_client(
    config: &ClientConfig,
    properties: &KafkaProperties,
) -> ConnectorResult<Arc<BaseConsumer<RwConsumerContext>>>