- 首先关于Kafka的source demo这个要去参考flink-kafka-connector， 给个传送：flink/flink-connectors/flink-connector-kafka at master · apache/flink · GitHub
- 关于Nebula 给出的demo使用list作为source只是为了构造出一个datastream，用于将该datastream写入Nebula，实际使用过程中可以使用任意flink 的source。
- datastream写入Nebula是批量写的，有个batch的配置
setBatch()可以控制批量大小。