te since Flink 1.14。*
*
*
You need to use "KafkaSource" and "KafkaSink" to finish your requirement.
Regards,
*Leo*
*
*
在 2023/6/7 23:27, Kadiyala, Ruthvik via user 写道:
Hi,
Please find below the code I have been using to consume a Kafka Stream
that is hosted on confl
Anyone using Kineis Analytics?
It is managed flink in AWS.
I am studying it now with the help of AWS. It looks very promising. It
automatically creates and manages savepoints when deploying new versions,
and changing parelelism. I will post more later.
--
*Leo Woessner*
*Domain Engineering
might be some reason
>> for this behaviour.
>> I would like to get the opinion of Flink experts on this. And if there
>> are any potential workarounds to get the desired behaviour.
>>
>> Kind regards
>> Ayush Verma
>>
>
--
*Leo Woessner*
*Domain Engineering*
*Pearson Education*
