我怎么读Kafka的最新作品?

5lwkijsr  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(361)

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

c9x0cxw0

c9x0cxw01#

设置 auto.offset.reset 属性设置为最新,您的消费者将始终读取最后一个条目。

相关问题