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 :) On Mon, Jan 10, 2022 at 6:22 AM Piotr Nowojski <pnowoj...@apache.org> wrote: > 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 need both at the very least a custom > `KafkaSourceReader` and `KafkaSource` to instantiate your custom > `KafkaSourceReader`. But I'm not sure if anyone has ever tried this so far. > > Best, > Piotrek > > pt., 7 sty 2022 o 21:18 Clayton Wohl <claytonw...@gmail.com> 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-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 local file system. >> At the documentation link above, Amazon recommends adding a hook to copy >> the keystore files from the classpath to a /tmp directory at runtime. Can >> KafkaSource do something similar? >> >
