首页 > TAG信息列表 > 消费群

kafka~消费群组如何重新消费

今天遇到一个问题,由于代码问题导致了很多kafka消息入到备用库,偏移量已经变成了最新;如何将偏移量重设到某个时间点,但消费群组重新去消费一次,是解决问题的关键,于是,使用了kafka/bin的sh程序,以下是解决问题的步骤: 查看某个组的topic偏移量,这步只是查看,没什么配置作用,只是作到心中有数