(pulsar) branch master updated: [fix][cli] Fix output of --print-metadata in cli consume (#25056)

[technoboy]

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

technoboy 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 02445364630 [fix][cli] Fix output of --print-metadata in cli consume 
(#25056)
02445364630 is described below

commit 02445364630a72a85697807e965541a6b1e9a21e
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Wed Dec 10 15:43:16 2025 +0200

    [fix][cli] Fix output of --print-metadata in cli consume (#25056)
---
 .../main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java
index b0686d034e5..55b189ee007 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java
@@ -134,11 +134,11 @@ public abstract class AbstractCmdConsume extends 
AbstractCmd {
                     encContext.getKeys().forEach((keyName, keyInfo) -> {
                         String metadata = 
Arrays.toString(keyInfo.getMetadata().entrySet().toArray());
                         sb.append("name:").append(keyName).append(", 
").append("key-value:")
-                                
.append(Base64.getEncoder().encode(keyInfo.getKeyValue())).append(", ")
+                                
.append(Base64.getEncoder().encodeToString(keyInfo.getKeyValue())).append(", ")
                                 
.append("metadata:").append(metadata).append(", ");
 
                     });
-                    sb.append(", 
").append("param:").append(Base64.getEncoder().encode(encContext.getParam()))
+                    sb.append(", 
").append("param:").append(Base64.getEncoder().encodeToString(encContext.getParam()))
                             .append(", 
").append("algorithm:").append(encContext.getAlgorithm()).append(", ")
                             
.append("compression-type:").append(encContext.getCompressionType()).append(", 
")
                             
.append("uncompressed-size").append(encContext.getUncompressedMessageSize()).append(",
 ")