From 6afa8a753bb81c9e4f581d5aee457df1e0caac41 Mon Sep 17 00:00:00 2001 From: SoMuchForSubtlety Date: Thu, 22 Jun 2023 18:08:08 +0200 Subject: [PATCH] Handle multiple cleanup policies cleanup.policy can be a comma-separated list https://kafka.apache.org/documentation/#topicconfigs_cleanup.policy --- cmd/kaf/topic.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/cmd/kaf/topic.go b/cmd/kaf/topic.go index 9ad07e3..a07dd1b 100644 --- a/cmd/kaf/topic.go +++ b/cmd/kaf/topic.go @@ -200,8 +200,12 @@ var describeTopicCmd = &cobra.Command{ var compacted bool for _, e := range cfg { - if e.Name == "cleanup.policy" && e.Value == "compact" { - compacted = true + if e.Name == "cleanup.policy" { + for _, setting := range strings.Split(e.Value, ",") { + if setting == "compact" { + compacted = true + } + } } }