Kafka consumer that writes messages to HDFS