This tutorial shows how to integrate Upstash Kafka with Apache Flink
mvn –version
in a terminal or in a command prompt to make sure you have
Maven downloaded.
It should print out the version of the Maven you have:
cd <folder path>
Run the following command:
pom.xml
file.
(<word>, 1)
.
Create LineSplitter class as following.
UPSTASH-KAFKA-*
placeholders with your cluster information.