[GitHub] [pulsar] xiaotongwang1 opened a new issue #12616: [BUG]KOP failed to get partition offset

[GitBox]

xiaotongwang1 opened a new issue #12616:
URL: https://github.com/apache/pulsar/issues/12616


   @hangc0276 @BewareMyPower @codelipenghui 紧急求助
   
   [](https://github.com/apache/pulsar/pull/11912)
   
   这个PR，在asyncReadEntry的时候做了ledger map匹配校验
   
   但是原有的接口：
   `    public PositionImpl getFirstPosition() {
           Long ledgerId = ledgers.firstKey();
           if (ledgerId == null) {
               return null;
           }
           if (ledgerId > lastConfirmedEntry.getLedgerId()) {
               checkState(ledgers.get(ledgerId).getEntries() == 0);
               ledgerId = lastConfirmedEntry.getLedgerId();
           }
           return new PositionImpl(ledgerId, -1);
       }`
   
   
当前出现场景，当一个分区创建了一个新的ledger，但是没有新消息发送，当前lastConfirmedEntry还是指向该分区的前一个ledger,当这个ledger过期之后,KOP目前去获取当前分区消息数会查询首个offset的时候，一直失败。
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org