flink1.12.x source数据源-kafka，从头读取数据 作者：马育民 • 2025-08-12 21:47 • 阅读：10001 需要掌握：[kafka教程-从头消费数据：查看偏移量、删除偏移量](https://www.malaoshi.top/show_1GW1fE1kC0sC.html "kafka教程-从头消费数据：查看偏移量、删除偏移量") # 注意 需要 **先停掉 flink 程序**，然后再按照 [kafka教程-从头消费数据：查看偏移量、删除偏移量](https://www.malaoshi.top/show_1GW1fE1kC0sC.html "kafka教程-从头消费数据：查看偏移量、删除偏移量") 删除 如果不停掉 flink 程序，**删除偏移量无效** ### 操作 1. 断开 **所有** 消费 **该主题** 的消费者（否则删除无效） 2. 查看某 group组 的消费偏移量 ``` kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group group_fl_dim --describe ``` 3. 删除消费偏移量 ``` kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group group_fl_dim --delete-offsets --topic fl-db ``` 原文出处：http://www.malaoshi.top/show_1GW1fEc3XVCi.html