From e5cf81581d5e4c2b42f80523734ed00bfea62f32 Mon Sep 17 00:00:00 2001 From: Andres Ivanov Date: Mon, 18 Mar 2019 11:57:19 -0400 Subject: [PATCH] Fix hardcoded compact --- cmd/kaf/topic.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/cmd/kaf/topic.go b/cmd/kaf/topic.go index d22f3695..f773ad93 100644 --- a/cmd/kaf/topic.go +++ b/cmd/kaf/topic.go @@ -175,7 +175,10 @@ var createTopicCmd = &cobra.Command{ panic(err) } - compact := "compact" + compact := "delete" + if compactFlag { + compact = "compact" + } err = admin.CreateTopic(args[0], &sarama.TopicDetail{ NumPartitions: partitionsFlag, ReplicationFactor: replicasFlag,