This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit bab7a376e8df6a9f7127b93c5772162d4c612069 Author: Lari Hotari <[email protected]> AuthorDate: Wed Dec 10 15:43:16 2025 +0200 [fix][cli] Fix output of --print-metadata in cli consume (#25056) (cherry picked from commit 02445364630a72a85697807e965541a6b1e9a21e) --- .../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(", ")
