Apache Flink

Hey all, I’m trying to connect a Flink SQL job to a Strimzi TLS Kafka cluster, running using the Flink K8s operator. I can’t find any documentation on how to configure the credentials, especially the truststore passwords. I can hard code them in the WITH(..) clause, or I guess in the flink-conf.yaml (so it is built into the image) but I’d prefer to pick them up from an ENV variable. Can I address env variables in the ‘WITH’ clause?

Hey, check <https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/table/kafka/#security|https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/table/kafka/#security>

Env vars are not supported out of the box, it’s something you need to implement yourself 

Ok, yes, I did see that one, but indeed wondered how to prevent hard coding credentials into queries. I’ll create some sort of template variable replacement.