Hi there,
I am looking art using Flink to implement a fan-out of events, but
discovered a couple of issues attempting to implement on AWS Kinesis
Analytics:
- the version of Flink is pinned to 1.13.2
- there is currently no version of Pyflink that supports OutputTag
Does anyone know if it is
27;m not sure if anyone has ever tried this so far.
>>
>> Best,
>> Piotrek
>>
>> pt., 7 sty 2022 o 21:18 Clayton Wohl napisał(a):
>>
>>> If I want to migrate from FlinkKafkaConsumer to KafkaSource, does the
>>> latter support this:
>>>
&g
>
> Best,
> Piotrek
>
> pt., 7 sty 2022 o 21:18 Clayton Wohl napisał(a):
>
>> If I want to migrate from FlinkKafkaConsumer to KafkaSource, does the
>> latter support this:
>>
>>
>> https://docs.aws.amazon.com/kinesisanalytics/latest/java/example-keysto
kaConsumer to KafkaSource, does the
> latter support this:
>
>
> https://docs.aws.amazon.com/kinesisanalytics/latest/java/example-keystore.html
>
> Basically, I'm running my Flink app in Amazon's Kinesis Analytics hosted
> Flink environment. I don't have reliable access
If I want to migrate from FlinkKafkaConsumer to KafkaSource, does the
latter support this:
https://docs.aws.amazon.com/kinesisanalytics/latest/java/example-keystore.html
Basically, I'm running my Flink app in Amazon's Kinesis Analytics hosted
Flink environment. I don't have rel
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*
*P
