flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nihat Hosgur <nhos...@gmail.com>
Subject Keep bootstrapped config updated with stream from Kafka
Date Thu, 19 Jan 2017 01:53:05 GMT
Hi all,

We bootstrap data from some DB and then like to keep it updated with
updates coming through Kafka. At spark it was kind of easy by utilizing
through UpdateStateByKey yet I'm kind of stuck to figure out how to do it
with Flink. I've taken a look into iterate yet I don't think it's meant to
do that.

Any input would be appreciated,
Nihat
-- 
Thanks,
Nihat

Mime
View raw message