Skip to content

Commit 395223e

Browse files
committed
Fix output of --print-metadata in cli consume
Converting bytes array to a String doesn't make sense. Issue found with errorprone
1 parent b3c5148 commit 395223e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -134,11 +134,11 @@ protected String interpretMessage(Message<?> message, boolean displayHex, boolea
134134
encContext.getKeys().forEach((keyName, keyInfo) -> {
135135
String metadata = Arrays.toString(keyInfo.getMetadata().entrySet().toArray());
136136
sb.append("name:").append(keyName).append(", ").append("key-value:")
137-
.append(Base64.getEncoder().encode(keyInfo.getKeyValue())).append(", ")
137+
.append(Base64.getEncoder().encodeToString(keyInfo.getKeyValue())).append(", ")
138138
.append("metadata:").append(metadata).append(", ");
139139

140140
});
141-
sb.append(", ").append("param:").append(Base64.getEncoder().encode(encContext.getParam()))
141+
sb.append(", ").append("param:").append(Base64.getEncoder().encodeToString(encContext.getParam()))
142142
.append(", ").append("algorithm:").append(encContext.getAlgorithm()).append(", ")
143143
.append("compression-type:").append(encContext.getCompressionType()).append(", ")
144144
.append("uncompressed-size").append(encContext.getUncompressedMessageSize()).append(", ")

0 commit comments

Comments
 (0)