c# - Confluent Kafka 为偏移位置返回 -1001

Question

我正在尝试Kafka使用Confluent Kafka.

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

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

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

附加信息

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

如果此消费者没有使用先前的消息，则取消设置。

我不确定我应该怎么做。

Answer 1

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

如果指定了 Offset.Invalid (-1001) 的偏移值，则消费将从上次提交的偏移量开始，如果尚未提交偏移量，则根据 'auto.offset.reset' 配置参数。

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