Kafka to HDFS pipeline