Get last entry is trying to read entry -1 (apache#7495)

yew1eb · Jul 10, 2020 · d8fd8ea · d8fd8ea
1 parent 9f9db24
commit d8fd8ea
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -1480,6 +1480,7 @@ private void getLargestBatchIndexWhenPossible(
                     .setPartition(partitionIndex).build();
 
             ctx.writeAndFlush(Commands.newGetLastMessageIdResponse(requestId, messageId));
+            return;
         }
 
         // For a valid position, we read the entry out and parse the batch size from its metadata.