Kafka consumer which writes to HDFS