Alternate way while using FlinkKafkaConsumer* (:
Will the Beam Flink runner code need several changes for this?
I want to use 'FlinkKafkaConsumer' with 'UnboundedFlinkSource' as present in 0.6.0 SDK and it's examples (
As I understand you are saying this support is not there now, correct? How else could I use a 'FlinkKafkaConsumer' at source level? Is there an alternate you would suggest if not possible?
By the away, if you mean that your custom source is implemented for
Flink, it's not supported. I meant the Beam source.
On 09/06/2018 09:31, Abdul Qadeer wrote:
> I would like to know if there is any way I can use 2.4.0 Beam's Source
> API for Flink 1.4.0 runner? I have a custom unbounded source implemented
> for Flink runner but I can not find the documentation to use it for 2.x
> Beam SDK. Looks like it was only supported in 0.x SDK? Any help appreciated.
Talend - http://www.talend.com