[BEAM-2852] Add support for Kafka as source/sink on Nexmark#5019

Merged

echauchot merged 3 commits intoapache:masterfrom aromanenko-dev:BEAM-2852-nexmark-kafka-source-sink

Apr 10, 2018

+153-4

Commits on Apr 10, 2018

[BEAM-2852] Added Kafka source of events and sink of results

vectorijk
authored and
aromanenko-dev
committed
[BEAM-2852] Fix the code that uses Long key whereas there is no key in the PCollection

echauchot
authored and
aromanenko-dev
committed
[BEAM-2852] Fix minor code style issues
aromanenko-dev
committed