[pulsar] 10/11: [pulsar-client] remove consumer reference from PulsarClient on subscription failure (#11758)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chenhang pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit bce43cbb4dbb4826c9c0ee9664cdc04ef6f291c5
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Tue Aug 24 06:01:35 2021 -0700

    [pulsar-client] remove consumer reference from PulsarClient on subscription failure (#11758)
    
    (cherry picked from commit c2bd23d1676e17135eb9a5044a939069c89588e9)
---
 .../main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
index c9e2067..727f2d6 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -877,6 +877,7 @@ public class MultiTopicsConsumerImpl<T> extends ConsumerBase<T> {
             .exceptionally(e -> {
                 log.warn("Failed subscription for createPartitionedConsumer: {} {}, e:{}",
                     topicName, numPartitions,  e);
+                consumer.cleanupMultiConsumer();
                 subscribeFuture.completeExceptionally(
                     PulsarClientException.wrap(((Throwable) e).getCause(), String.format("Failed to subscribe %s with %d partitions", topicName, numPartitions)));
                 return null;