如果我有一个带有一个分区(和一个副本)的空主题,并且我查询低/高水印,它将返回0/0。如果分区中有一条消息,它将返回0/1。但要得到最后一条(也是唯一一条消息),我必须从0开始阅读。特别是,我的应用程序在启动时需要读取分区中的最新(上次写入的)消息。所以我用这个代码:
consumer.Assign(new[] { new TopicPartitionOffset(topicPartition, new Offset(last - 1)) });
当最后一个偏移>0时(最后是高水位线的返回值)
这似乎是可行的,但它似乎不符合我读过的文档,其中指出高水位线是最后复制的消息的偏移量。从我的实验来看,它似乎更高。我是不是漏了什么?
暂无答案!
目前还没有任何答案,快来回答吧!