producer一直生产消息到topic1中,consumer1获取该topic的消息,group.id为client1,该group中只有consumer1这一个消费者,某一时刻关闭这个consumer1,一段时间后重新启动consumer1,其group.id仍旧设置为client1,获取到的消息流是从上次断开的时刻开始的, 而中间这段时间产生的消息我不需要, 如何让这个consumer1获取到的数据流是producer从consumer1重新启动的这个时刻开始产生的消息,让consumer1获取最新的消息
1 个解决方案
我也遇到这个问题,你是怎么解决的啊