Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5102
LGTM.
+1 to merge this now, and we think about removing the source as well as
reworking the doc example to not use it (I think it might be nice to directly
kick off the docs with an intro example that read / writes to Kafka), as a
separate issue.---
