Pulsar Client: missing return in ConsumerImpl#internalGetLastMessageI…

…dAsync (apache#10974)
mfleming · Jun 18, 2021 · a3dc8d2 · a3dc8d2
1 parent 9af9361
commit a3dc8d2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -2027,6 +2027,7 @@ private void internalGetLastMessageIdAsync(final Backoff backoff,
                         String.format("The command `GetLastMessageId` is not supported for the protocol version %d. " +
                                 "The consumer is %s, topic %s, subscription %s", cnx.getRemoteEndpointProtocolVersion(),
                             consumerName, topicName.toString(), subscription)));
+                return;
             }
 
             long requestId = client.newRequestId();