This project is use a simple Flink job to show how to integrate Apache Kafka to Flink using the Flink Connector for Kafka. flink 1.18.0 jdk 8 or higher
jdk11 && mvn clean package -DskipTests && jdk8 && mvn exec:java -Dexec.mainClass=com.jacob.ReadFromKafka
flink run ./target/filink-hello-1.0-SNAPSHOT.jar flink cancel $JOB_ID
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/cli/
flink list