OSS Streaming data pipeline on GCP

Open source version of raycom. Replaced the Pub/Sub with Kafka, and Dataflow with Flink

Maven

Use maven to generate a skeleton flink project

mvn archetype:generate \
    -DarchetypeGroupId=org.apache.flink \
    -DarchetypeArtifactId=flink-quickstart-java \
    -DarchetypeVersion=1.20.0