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?
