You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/12/15 07:54:02 UTC
(pulsar) 03/10: [fix][cli] Fix output of --print-metadata in cli consume (#25056)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 2012c1daaefe8e2f69023c44d708b7d248741375
Author: Lari Hotari <lh...@users.noreply.github.com>
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 33df4aca96d..4dcdb2af5ca 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
@@ -135,11 +135,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(", ")