Confluent Kafka返回偏移位置-1001

Question

3

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

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

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

尽管我做了什么都会得到-1001的值，这是哪里出了问题？ 附加信息

我认为这可能是由于未设置。文档上说：

无前一条消息被此消费者消耗时将其设置为未设置。

虽然我不确定我该怎么办。

- runnerpaul

2

嗯，就像消息所说的那样，它意味着没有人消费该主题分区并提交了偏移量。因此，默认情况下返回“未设置（-1001）”。您期望得到什么输出？ - rytisk

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Pickled · Accepted Answer

你没有做错任何事情，那是默认值。从文档中可以看出：

如果指定了Offset.Invalid（-1001）的偏移值，则消费将从上次提交的偏移量或根据“auto.offset.reset”配置参数恢复，如果尚未提交偏移量。

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