fix msg

travisjeffery · Oct 17, 2017 · 84d27a9 · 84d27a9
1 parent a1f6c88
commit 84d27a9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/cmd/jocko/main.go b/cmd/jocko/main.go
@@ -106,8 +106,6 @@ func cmdBrokers(logger *simplelog.Logger) int {
 }
 
 func cmdCreateTopic(logger *simplelog.Logger) int {
-	fmt.Fprintf(os.Stdout, "Creating topic: %v\n", *createTopicTopic)
-
 	addr, err := net.ResolveTCPAddr("tcp", *createTopicBrokerAddr)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "error shutting down store: %v\n", err)
@@ -140,7 +138,7 @@ func cmdCreateTopic(logger *simplelog.Logger) int {
 		}
 	}
 
-	fmt.Printf("Created topic: %v\n", *createTopicTopic)
+	fmt.Printf("created topic: %v\n", *createTopicTopic)
 
 	return 0
 }