C# Kafka重置到最新的偏移量，即从指定的Partition订阅消息使用Assign方法

在使用Kafka的过程中，消费者断掉之后，再次开始消费时，消费者会从断掉时的位置重新开始消费。 场景再现：比如昨天消费者晚上断掉了，今天上午a56爆大奖在线娱乐们会发现kafka消费的数据不是最新的，而是昨天晚上的数据，由于数据量比较多，也不会及时的消费到今天上午的数据，这个时候就需要a56爆大奖在线娱乐们对偏移量进行重置为最新的，以
posted @ 2023-04-11 16:35  峨嵋峰  阅读(660)  评论(0)  编辑  收藏  举报