Hi Everyone Does anyone have some examples of managing Secrets in Flink Sql. The Connectors like Kafka generally require secrets for connecting and I want to avoid placing it in Sql Scripts? For example can you reference an Env Var inside a SQL script? Thanks

Make a catalogue with the credentials and use that?

Thanks Ben that is an option. It looks like Pyflink might be a better option for standing up Connectors etc. as it can handle things like Secrets and configuration better.

That always works :) Pyflink is not without it's own issues, but it's a good approach. We've got a secrets manager which works with SQL baked into our offering so I tend to forget the table API options.