pub async fn build_kafka_client( connection: &KafkaConnectionConfig, ) -> Result<Client>
Builds a kafka Client.