Merge pull request birdayz#149 from Achillesxu/feature/kaf_node_add_c…

…ontroler_info the output of kaf nodes add controller info
Achillesxu · Mar 12, 2021 · aa3d781 · aa3d781
2 parents e60a1cc + ca1bd31
commit aa3d781
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,4 +1,5 @@
 /cmd/kaf/kaf
 /dist
 /kaf*
+.idea
 
diff --git a/cmd/kaf/node.go b/cmd/kaf/node.go
@@ -33,7 +33,7 @@ var nodeLsCommand = &cobra.Command{
 	Run: func(cmd *cobra.Command, args []string) {
 		admin := getClusterAdmin()
 
-		brokers, _, err := admin.DescribeCluster()
+		brokers, ctlID, err := admin.DescribeCluster()
 		if err != nil {
 			errorExit("Unable to describe cluster: %v\n", err)
 		}
@@ -44,11 +44,11 @@ var nodeLsCommand = &cobra.Command{
 
 		w := tabwriter.NewWriter(outWriter, tabwriterMinWidth, tabwriterWidth, tabwriterPadding, tabwriterPadChar, tabwriterFlags)
 		if !noHeaderFlag {
-			fmt.Fprintf(w, "ID\tADDRESS\t\n")
+			_, _ = fmt.Fprintf(w, "ID\tADDRESS\tCONTROLLER\t\n")
 		}
 
 		for _, broker := range brokers {
-			fmt.Fprintf(w, "%v\t%v\t\n", broker.ID(), broker.Addr())
+			_, _ = fmt.Fprintf(w, "%v\t%v\t%v\t\n", broker.ID(), broker.Addr(), broker.ID() == ctlID)
 		}
 
 		w.Flush()