/flink-consumer

This contains code for consuming event from an Event Hub/Kafka

Primary LanguageJava

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.