Simple API for writing to filesystem in general.
Helper class for accessing HDFS (hardcoded URI for hdfs namenode).
IWriter implementation for HDFS.
Interface movement
Simple test for writing to hdfs. On Cloudera 5 there is a need for some
changes in pom.xml (hadoop-commons is instead of hadoop-core).
Simple Kafka consumer
Helper class for accessing message streams (some parameters hardcoded).
Console and hdfs test consumers.