[pulsar] branch master updated: fix InvalidMessageException throw message (#17910)

[aloyszhang]

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

aloyszhang 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 368bf3797e7 fix InvalidMessageException throw message (#17910)
368bf3797e7 is described below

commit 368bf3797e74b09c24d3cb1d678834d3b89f84bd
Author: LinChen <1572139...@qq.com>
AuthorDate: Sun Oct 9 18:01:07 2022 +0800

    fix InvalidMessageException throw message (#17910)
    
    Co-authored-by: leolinchen <leolinc...@tencent.com>
---
 .../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java     | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
index c51562157df..e2e78671e35 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
@@ -459,9 +459,7 @@ public class ProducerImpl<T> extends ProducerBase<T> 
implements TimerTask, Conne
             int compressedSize = compressedPayload.readableBytes();
             if (compressedSize > ClientCnx.getMaxMessageSize() && 
!this.conf.isChunkingEnabled()) {
                 compressedPayload.release();
-                String compressedStr = (!isBatchMessagingEnabled() && 
conf.getCompressionType() != CompressionType.NONE)
-                                           ? "Compressed"
-                                           : "";
+                String compressedStr = conf.getCompressionType() != 
CompressionType.NONE ? "Compressed" : "";
                 PulsarClientException.InvalidMessageException 
invalidMessageException =
                         new PulsarClientException.InvalidMessageException(
                                 format("The producer %s of the topic %s sends 
a %s message with %d bytes that exceeds"