flink-kafka-streaming

Flink Kafka Streaming Examples

1. FlinkKafkaSimpleStreamLocal.java - Flink exmaple to consume from Secured Kafka topic on local (eclipse or intellij)
2. FlinkKafkaSimpleStream.java - Flink example to consume from Secured Kafka topic
3. FlinkKafkaDeDupStateStream.java - Flink example to remove duplicates using Flink ValueState
4. FlinkKafkaDeDupStateStream.java - Flink example to remove duplicates using custom state implemenation (google cache)