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