Override public void processBroadcastElementString jsonStr Context ctx CollectorJSONObject out throws Exception 为了操作方便将jsonstr转换为jsonObj JSONObject jsonObj = JSONparseObjectjsonStr;

这段代码是 Flink 实现动态配置的关键部分，主要是将配置信息封装为 kv 并放到广播状态中，以便在整个 Flink 应用程序中进行共享和访问。具体实现中，首先获取操作类型和广播状态，如果是删除操作，则将对应的配置信息从广播状态和配置 Map 中删除掉；否则，将配置信息封装为 kv 放到广播状态和配置 Map 中。其中，key 是由 sourceTable 和 sourceType 拼接而成的字符串，用于在广播状态和配置 Map 中进行唯一标识和访问。这样，当配置信息发生变化时，只需要修改配置表中的数据，Flink 应用程序就能自动获取到最新的配置信息，从而实现了动态配置。