A Basic Flink Application Consuming & Aggregating Kafka Messages - View it on GitHub