各位好:
        背景:Flink版本1.6.4,数据源为Kafka的主题A,B,消费者组相同
        操作步骤:1.使用SavePoint取消任务。
        2.修改代码将B去掉,只消费A主题。
        3.从SavePoint启动任务,发现消费者组在B主题下的偏移量也回到了任务停止时的偏移量,之后偏移量马上变成了最新并继续消费。
        想知道为什么修改代码不生效。

回复