Hello,

I use Flink SQL API to process a data stream from Kafka. To process these
data, I use some configurations loaded from an HTTP endpoint once at
initialization.

The configuration is loaded only once at job initialization. So it works
well with a static configuration, but do not handle dynamic ones.

How to handle dynamic configuration, without having to reload the
configuration at each message?

Thanks
嘉琪

Reply via email to