aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_mq_topic_create.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2023-09-24 15:26:49 -0700
committerchrislu <chris.lu@gmail.com>2023-09-24 22:00:43 -0700
commitb3f94feeded8f0beb411ade49bda09baa3c5443f (patch)
tree0efca37270f22a4cb7afaaaaf14ed3d9c215ee64 /weed/shell/command_mq_topic_create.go
parentd74348048ad4259e14e7d948106e282b27c326f7 (diff)
downloadseaweedfs-b3f94feeded8f0beb411ade49bda09baa3c5443f.tar.xz
seaweedfs-b3f94feeded8f0beb411ade49bda09baa3c5443f.zip
do create topic
Diffstat (limited to 'weed/shell/command_mq_topic_create.go')
-rw-r--r--weed/shell/command_mq_topic_create.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/shell/command_mq_topic_create.go b/weed/shell/command_mq_topic_create.go
index b09f94451..d1b1bdd23 100644
--- a/weed/shell/command_mq_topic_create.go
+++ b/weed/shell/command_mq_topic_create.go
@@ -2,6 +2,7 @@ package shell
import (
"context"
+ "encoding/json"
"flag"
"fmt"
"github.com/seaweedfs/seaweedfs/weed/pb"
@@ -58,7 +59,8 @@ func (c *commandMqTopicCreate) Do(args []string, commandEnv *CommandEnv, writer
if err != nil {
return err
}
- fmt.Fprintf(writer, "response: %+v\n", resp)
+ output, _ := json.MarshalIndent(resp, "", " ")
+ fmt.Fprintf(writer, "response:\n%+v\n", string(output))
return nil
})