Hello, I am trying to do some benchmark testing with flink streaming. When flink reads a message in from Kafka, I want to write a timestamp to redis. How can I modify the existing kafka consumer code to do this? What would be easiest way to do something like this? Thanks for your help!
Best, Jerry
