WIP
[demos/kafka/wordcount] / wordcount / splitter / SplitterStreamProcessor.java