This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch branch-2.6 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9eee486de035f27de7b38670affc90698d7087fa Author: Matteo Merli <[email protected]> AuthorDate: Fri Jul 10 10:41:30 2020 -0700 Get last entry is trying to read entry -1 (#7495) (cherry picked from commit d8fd8eaaa2e2dcb93ac69d80981365048b76c0b2) --- .../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java | 1 + 1 file changed, 1 insertion(+) 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 index 3131a76..0b7499d 100644 --- 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 @@ public class ServerCnx extends PulsarHandler { .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.
