我正在使用来自confluent的.net客户端库。
我需要连接到一个主题并读回其中最后一条信息。我不能使用绝对偏移量,因为我不知道它,逻辑偏移量似乎没有帮助。特别地 Offset.End
将光标刚好放在最后一个条目之后,因此任何后续的读取调用(如 Consume
)将返回更新的条目(如果可用),或者 null
,但不是通话时最新的。
实际上,我在想,用Kafka的话来说,它是否是一个合理的用例(我对它很陌生)。我找到了一些类似案例的例子,但没有什么能解释这一个,我也找不到一个好的方法来适应我的其他案例。我还试着用光标做一些算术运算,比如求和/减法(即。 Offset.End-1
或者 Offset.End-new Offset(1)
),但我得到的显然是不正常的游标,不能使用。这让我想:为什么 +
以及 -
已经被定义为 Offset
如果他们允许你设计无效的值?但那是另一回事。
1条答案
按热度按时间c9x0cxw01#
设置
auto.offset.reset
属性设置为最新,您的消费者将始终读取最后一个条目。