Hi Darius,
I fear that your use case has not been directly supported. You can
certainly use the workarounds for that and I don't know of a better way.
Consumer/Producer configs both in legacy and unified implementations are
only meant to be statically settable.
For the new unified interfaces, the
I've overridden v1.11.3 FlinkKafkaConsumer's 'open' method in order to set
TLS configuration for kafka from the task manager node where the kafka
consumer is running (TLS configuration differs between job manager and each
task manager in our environment, which is why we use 'open' vs. setting
confi
