the output of kaf nodes add controller info

birdayz · Mar 10, 2021 · 92dce28 · 92dce28
1 parent 67b66ea
commit 92dce28
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()