Skip to content

Commit ec4630b

Browse files
authored
Merge pull request #219 from joeirimpan/fatal-logs
fix: Set exit flag when create/delete command fails
2 parents 6221d27 + 7a86f51 commit ec4630b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

cmd/kaf/topic.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ var createTopicCmd = &cobra.Command{
279279
},
280280
}, false)
281281
if err != nil {
282-
fmt.Printf("Could not create topic %v: %v\n", topicName, err.Error())
282+
errorExit("Could not create topic %v: %v\n", topicName, err.Error())
283283
} else {
284284
w := tabwriter.NewWriter(outWriter, tabwriterMinWidth, tabwriterWidth, tabwriterPadding, tabwriterPadChar, tabwriterFlags)
285285
fmt.Fprintf(w, "\xE2\x9C\x85 Created topic!\n")
@@ -325,7 +325,7 @@ var deleteTopicCmd = &cobra.Command{
325325
topicName := args[0]
326326
err := admin.DeleteTopic(topicName)
327327
if err != nil {
328-
fmt.Fprintf(outWriter, "Could not delete topic %v: %v\n", topicName, err.Error())
328+
errorExit("Could not delete topic %v: %v\n", topicName, err.Error())
329329
} else {
330330
fmt.Fprintf(outWriter, "\xE2\x9C\x85 Deleted topic %v!\n", topicName)
331331
}

0 commit comments

Comments
 (0)