[pulsar-client] remove consumer reference from PulsarClient on subscr…

…iption failure (apache#11758)
lionelcao · Aug 24, 2021 · c2bd23d · c2bd23d
1 parent 9558c54
commit c2bd23d
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -877,6 +877,7 @@ public static <T> MultiTopicsConsumerImpl<T> createPartitionedConsumer(PulsarCli
             .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;