Skip to content

Latest commit

 

History

History
9 lines (8 loc) · 461 Bytes

README.md

File metadata and controls

9 lines (8 loc) · 461 Bytes
Raw

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.