Confluent Kafka 为偏移位置返回 -1001答案

【问题标题】：Confluent Kafka returns -1001 for offset positionConfluent Kafka 为偏移位置返回 -1001
【发布时间】：2021-06-29 21:25:07
【问题描述】：

我正在尝试使用Confluent Kafka 获取Kafka 偏移量。

这是我用来获取它的代码：

var offsetPosition = consumer.Position(new TopicPartition(topicConfiguration.Topic, topicConfiguration.Partition));

不过，它总是给我一个 -1001 的值。我做错了什么？

其他信息

我认为这可能是因为它是Unset。文档是这样说的：

如果此消费者之前没有消费过消息，则取消设置。

不过，我不确定我应该怎么做。

【问题讨论】：

【解决方案1】：

您没有做错任何事情，这是默认值。来自文档：

如果指定了偏移值 Offset.Invalid (-1001)，消耗将从最后提交的偏移量恢复，或根据 'auto.offset.reset' 配置参数，如果没有偏移量尚未提交。

如果要指定从哪里开始，可以使用consumer.Assign方法。

【讨论】：