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

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


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 40f66633b44 [fix][client]Fix checkstyle issue of ConsumerBase.java
40f66633b44 is described below

commit 40f66633b4411b07c6a72242d24b816d116c344c
Author: fengyubiao <[email protected]>
AuthorDate: Wed May 27 11:57:11 2026 +0800

    [fix][client]Fix checkstyle issue of ConsumerBase.java
---
 .../src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
index a4e5bef3083..2cc50266013 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
@@ -337,7 +337,8 @@ public abstract class ConsumerBase<T> extends HandlerState 
implements Consumer<T
                         + " crucial issue: this message will never be consumed 
until the consumer is restarted or"
                         + " the topic is unloaded. Under normal circumstances, 
this won't happen. It only occurs when"
                         + " user itself has completed the completable future 
object returned by"
-                        + " \"consumer.receiveAsync()\". message={}, 
cancelled={}", message, receivedFuture.isCancelled());
+                        + " \"consumer.receiveAsync()\". message={}, 
cancelled={}", message,
+                        receivedFuture.isCancelled());
             }
         });
     }

Reply via email to