Ah, I see. Pitty. You could always use reflection if you really had to, but
that's of course not a long term solution.
I will raise this issue to the KafkaSource/AWS contributors.
Best,
Piotr Nowojski
pon., 10 sty 2022 o 16:55 Clayton Wohl napisał(a):
> Custom code can create subclasses of Fli
Custom code can create subclasses of FlinkKafkaConsumer, because the
constructors are public. Custom code can't create subclasses of KafkaSource
because the constructors are package private. So the same solution of
creating code subclasses won't work for KafkaSource.
Thank you for the response :)
Hi Clayton,
I think in principle this example should be still valid, however instead of
providing a `CustomFlinkKafkaConsumer` and overriding it's `open` method,
you would probably need to override
`org.apache.flink.connector.kafka.source.reader.KafkaSourceReader#start`.
So you would most likely n
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 reliable access to the
