关于kafka 不消费的问题

Panda 发表于: 2025-01-09   最后更新时间: 2025-02-08 10:57:37   124 游览

现在遇到了如下问题，向TOPIC 推送数据，但是客户端不消费了，使用 kafka-consumer-groups.sh 脚本查看得到如下信息

GROUP           TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                                HOST            CLIENT-ID
TO_WMS      TO_WMS_send 0          126              26              100               consumer-TO_WMS-1-492af100-b028-4d52-a974-e79b3eb8124a /39.108.44.134  consumer-TO_WMS-1
TO_WMS      TO_WMS_send 1          229              209              20               consumer-TO_WMS-1-492af100-b028-4d52-a974-e79b3eb8124a /39.108.44.134  consumer-TO_WMS-1
TO_WMS      TO_WMS_send 2          139              129              10               consumer-TO_WMS-2-32710e9e-827d-4a5b-897b-8d2fc0bfde33 /39.108.44.134  consumer-TO_WMS-2

如何才能把没有消费的信息给消费掉呢？
现在没有找到解决办法 都是删除掉topic 在重新推送，这样就造成了数据丢失

kafka
发表于 2025-01-09
Panda
添加评论

手动调整 offset

可以尝试手动调整 offset，定位成最新的：

kafka-consumer-groups.sh --bootstrap-server <KAFKA_BROKER> --group TO_WMS --reset-offsets --to-latest --execute

或将偏移量重置为最早：

kafka-consumer-groups.sh --bootstrap-server <KAFKA_BROKER> --group TO_WMS --reset-offsets --to-earliest --execute

然后重启消费者进程，让其从最新或最早的 offset 重新开始消费。

回复
回答于 14天前
半兽人
Panda -> 半兽人 13天前

好的 感谢 我试下

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。