提问说明

1、现在遇到了如下问题,向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 在重新推送,这样就造成了数据丢失