flink动态修改kafka数据源问题

在 Apache Flink 中，动态修改 Kafka 数据源是一个比较复杂的需求，因为 Flink 的 Kafka Consumer 通常是在初始化时就配置好的，并且会静态地消费指定的 Topic。一旦开始运行，它不会自动感知 Topic 的变化。

使用 Flink Kafka Connector 的动态 Topic 功能：
Flink 的 Kafka Connector 支持动态 Topic，这意味着你可以在运行时添加或删除 Topics。你需要在创建 Kafka Consumer 时配置 subscribe 方法来订阅一个空字符串或者使用 subscribePattern 方法来使用某种模式匹配 Topics。

properties.setProperty("bootstrap.servers", "localhost:9092");
properties.setProperty("group.id", "test");
FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>(
    "pattern", // 使用订阅模式
    new SimpleStringSchema(),
    properties);
kafkaConsumer.setStartFromGroupOffsets(); // 从组偏移量开始消费