I would also suggest to create a mapper after the source. Make sure the
mapper is chained to the kafka source, then, you'll not really see a big
delay in the timestamp written to redis.
Just out of curiosity, why do you need to write a timestamp to redis for
each record from Kafka?
On Wed, Oct 14
> On 12 Oct 2015, at 22:47, Jerry Peng wrote:
>
> 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 easies
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,
