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

[lhotari]

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

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


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

commit 39dd1cda2d01a6d472b7a39115a774958a837be1
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 a59a67adbaa..eecd51c788f 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
@@ -2020,6 +2020,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);
                                     }