Hi,

I am looking for a "stream" join between:

* new data from a Kafka topic
* reference data from a compacted Kafka topic

Datastream.connect() works, but for a key, a join may occur before the
corresponding reference data has been read by Flink. And this is, of
course, a problem.

Is there a mean to load the compacted topic content before the join occurs,
before the join really starts ?

According to some previous archived emails, and also the "FLIP-17", this
feature is not implemented. Still, I am not sure about latest version
status, so my question.

If not implemented, is there a way to overcome the limitation, and achieve
the expected result (join) ?

Thanks.

Regards,
Dominique

Reply via email to