Overview
Apache Flink provides various connectors to integrate with other systems. In this article, I will share an example of consuming records from Kafka through FlinkKafkaConsumer
and producing records to Kafka using FlinkKafkaProducer
.
Setup
I installed Kafka locally and created two Topics, TOPIC-IN
and TOPIC-OUT
.