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? >
