[pulsar] branch branch-2.11 updated: [fix][client] Fix async completion in ConsumerImpl#processPossibleToDLQ (#19392)

[technoboy]

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

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


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new a23b5e53893 [fix][client] Fix async completion in 
ConsumerImpl#processPossibleToDLQ (#19392)
a23b5e53893 is described below

commit a23b5e5389350709659f8262a8f8327372dbf6bf
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Thu Feb 2 14:07:19 2023 +0200

    [fix][client] Fix async completion in ConsumerImpl#processPossibleToDLQ 
(#19392)
---
 .../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java        | 1 +
 1 file changed, 1 insertion(+)

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
index 67341898e0e..8c3a400ea44 100644
--- 
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
@@ -2072,6 +2072,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T> 
implements ConnectionHandle
                                         log.warn("[{}] [{}] [{}] Failed to 
acknowledge the message {} of the original"
                                                         + " topic but send to 
the DLQ successfully.",
                                                 topicName, subscription, 
consumerName, finalMessageId, ex);
+                                        result.complete(false);
                                     } else {
                                         result.complete(true);
                                     }