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

本文主要是介绍C# Kafka重置到最新的偏移量，即从指定的Partition订阅消息使用Assign方法，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

在使用Kafka的过程中，消费者断掉之后，再次开始消费时，消费者会从断掉时的位置重新开始消费。

场景再现：比如昨天消费者晚上断掉了，今天上午我们会发现kafka消费的数据不是最新的，而是昨天晚上的数据，由于数据量比较多，也不会及时的消费到今天上午的数据，这个时候就需要我们对偏移量进行重置为最新的，以获取最新的数据。

前提，我们使用的AutoOffsetReset配置是Latest，即从连接到Kafka那一刻开始消费之后产生的消息，之前发布的消息不在消费，这也是默认的配置。

关于AutoOffsetReset这个枚举的配置项如下：

• latest (default) which means consumers will read messages from the tail of the partition
  最新(默认) ，这意味着使用者将从分区的尾部读取消息，只消费最新的信息，即自从消费者上线后才开始推送来的消息。那么会导致忽略掉之前没有处理的消息。
• earliest which means reading from the oldest offset in the partition
  这意味着从分区中最早的偏移量读取；自动从消费者上次开始消费的位置开始，进行消费。
• none throw exception to the consumer if no previous offset is found for the consumer's group
  如果没有为使用者的组找到以前的偏移量，则不会向使用者抛出异常。

接下来，我们直接使用下面这一段代码即可：

使用Assign订阅指定的分区，注意最后还需要使用Subscribe方法订阅

consumer.Assign(new TopicPartitionOffset(new TopicPartition(topic, new Partition(1)),Offset.End));//从指定的Partition订阅消息使用Assign方法

consumer.Subscribe(topic);//订阅消息使用Subscribe方法

从指定的分区获取数据，并且指定了对应的偏移量

 关于Offset这个枚举不同配置项的说明如下：

这篇关于C# Kafka重置到最新的偏移量，即从指定的Partition订阅消息使用Assign方法的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！