Merge "Source code initial workingDraft kafka2hdfs writer."