Kafka consumer that write to HDFS