Hi, We would like to enable sort of a feature flag functionality for flink jobs.
The idea would be to use broadcast state reading from a configuration topic and then ALL operators with logic would listen to this state. This documentation: https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/datastream/fault-tolerance/broadcast_state/ explains how a certain operator can use this broadcast state but the problem we are having is understanding how we can share the same state across many different operators. One way is to create multiple streams, one per operator reading from the same topic and then connect to the multiple operators in a keyedbroadcastprocessfunction but this seems overkill Is there an elegant solution to this problem? regards, Oscar
