kafka教程-从头消费数据:查看偏移量、删除偏移量 作者:马育民 • 2025-08-12 20:13 • 阅读:10009 # 说明 同一个 `group组`,消费数据后,再次消费时,是从上一个位置继续消费,相当于迅雷的断点续传 ### 如何从头读取数据 - 换一个新的group组,并设置从头读取数据(简单) - 删除该group组的偏移量(需要敲命令) # 删除该group组的偏移量 1. 先查看该group组的偏移量 2. 删除 3. 再次查看是否生效 ### 查看某 group组 的消费偏移量 通过下面命令查看: ``` kafka-consumer-groups.sh --bootstrap-server 【kafka服务器】:9092 --group 【group组】 --describe ``` #### 例子 ``` kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group flink_cdc_kafka4 --describe ``` 执行结果: [](https://www.malaoshi.top/upload/0/0/1GW1fDBArtSP.png) 可以看到: - 当前偏移量是 `84064` - 最后偏移量是 `84064` ### 删除该组在该主题的偏移量 ``` kafka-consumer-groups.sh --bootstrap-server 【kafka服务器】:9092 --group 【group组】 --delete-offsets --topic 【主题】 ``` #### 例子 ``` kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group flink_cdc_kafka4 --delete-offsets --topic fl-db ``` [](https://www.malaoshi.top/upload/0/0/1GW1fDyGCIf1.png) 表示删除成功 ### 再次查看 ``` kafka-consumer-groups.sh --bootstrap-server hadoop1:9092 --group flink_cdc_kafka4 --describe ``` 执行结果: [](https://www.malaoshi.top/upload/0/0/1GW1fE1GMfg9.png) 已经不存在了 原文出处:http://www.malaoshi.top/show_1GW1fE1kC0sC.html