Elastic data processing with Apache Pulsar and Apache Flink - View it on GitHub