Getting Started

Steps for running in Intellij,

1. Clone this repo.
2. From Intellij, navigate File->Open->Project->Select the already cloned project.
3. Edit the EH name in FlinkTestConsumer.java and broker name & connection string in consumer.config (if required)
4. From the Maven tool window, perform the lifecycle - clean and compile.
5. Run the main class ,FlinkTestConsumer.java.
6. Clone and run project flink-produce-ek and flink-consume-produce-ek.