Kafka Source and Sink.
Check example at: https://github.com/apache/incubator-gearpump/tree/master/examples/streaming/kafka
