#Config
- Install and Configure Redis on local.
- Install and Configure Kafka along with zookeeper
- Start Kafka
- Clone project and import this into eclipse or Spring STS.
- Start the class KafkaFlinkDemoApplication as Java Application.
- Run http://localhost:8090/producer in browser to start producer.
- Run http://localhost:8090/consumer in browser to start consumer.
#Now to see the output of this flink window and filter operation
- Run command redis-cli to open redis command prompt.
- Select db 1 (Run command select 1)
- now Run KEYS * to see the output.
#check url http://localhost:8090/stats/gainers