[fix][client] Fix orphan consumer when reconnection and closing are c…

…oncurrency executing (#22958)
apache · Jun 25, 2024 · 69b2739 · 69b2739
1 parent aa03c0e
commit 69b2739
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -1088,7 +1088,7 @@ public void connectionFailed(PulsarClientException exception) {
     }
 
     @Override
-    public CompletableFuture<Void> closeAsync() {
+    public synchronized CompletableFuture<Void> closeAsync() {
         CompletableFuture<Void> closeFuture = new CompletableFuture<>();
 
         if (getState() == State.Closing || getState() == State.Closed) {