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

[chenhang]

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 <rdhaba...@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;