You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/11/18 09:31:27 UTC
[pulsar] 04/12: [pulsar-admin] Print topic internal info as formatted json (#12709)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 985ef03c4df6c680874835130121e9e33ba1beba
Author: Ruguo Yu <ji...@163.com>
AuthorDate: Wed Nov 10 16:24:49 2021 +0800
[pulsar-admin] Print topic internal info as formatted json (#12709)
(cherry picked from commit bcc8243c97a99173c9907500f25031fc905cc802)
---
.../src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index cdd91b1..3d522ff 100644
--- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -28,6 +28,8 @@ import com.beust.jcommander.converters.CommaParameterSplitter;
import com.google.common.collect.Lists;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.Unpooled;
@@ -587,7 +589,8 @@ public class CmdTopics extends CmdBase {
@Override
void run() throws PulsarAdminException {
String topic = validateTopicName(params);
- String result = getTopics().getInternalInfo(topic);
+ String internalInfo = getTopics().getInternalInfo(topic);
+ JsonObject result = JsonParser.parseString(internalInfo).getAsJsonObject();
Gson gson = new GsonBuilder().setPrettyPrinting().create();
System.out.println(gson.toJson(result));
}