kafka consumer重新连接后如何获取当前最新数据

时间:2022-03-26 19:07:34
producer一直生产消息到topic1中,consumer1获取该topic的消息,group.id为client1,该group中只有consumer1这一个消费者,某一时刻关闭这个consumer1,一段时间后重新启动consumer1,其group.id仍旧设置为client1,获取到的消息流是从上次断开的时刻开始的, 而中间这段时间产生的消息我不需要,     如何让这个consumer1获取到的数据流是producer从consumer1重新启动的这个时刻开始产生的消息,让consumer1获取最新的消息

1 个解决方案

#1


我也遇到这个问题,你是怎么解决的啊

#1


我也遇到这个问题,你是怎么解决的啊