On 2021/01/11 14:12, [email protected] wrote:
a) As mentioned by you "KafkaSource" was introduced in Flink 1.12 so, I suppose we have to upgrade to this version of Flink. Can you share the link of the stable Flink image (containerized version) to be used in our set-up keeping in mind we are to use KafkaSource.
Unfortunately, there is a problem with publishing those images. You can check out [1] to follow progress. In the meantime you can try and build the image yourself or use the one that Robert pushed to his private account.
b) Also kindly share details of the corresponding compatible version of "Kafka" (containerized version) to be used for making this work as I understand there is constraint on version of Kafka required to make it work.
I believe Kafka is backwards compatible since at least version 1.0, so any recent enough version should work.
Best, Aljoscha
