jitkasempin/kafka_flink_deduplicate1

This project consume the message from Kafka topic using Flink and do deduplication on the incoming message.

Java