From 7bb38e6a2d6713510c0971b12227f697fe6422d5 Mon Sep 17 00:00:00 2001 From: omnilinguist Date: Tue, 31 Oct 2017 01:58:25 -0700 Subject: [PATCH] Fix bug in --use-tags --- main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.go b/main.go index 372bc66..08f505e 100644 --- a/main.go +++ b/main.go @@ -91,7 +91,7 @@ func main() { lag := tOffset - cgOffset log.Info("Topic: %s, Partition: %d, Consumer Group: %s, Lag: %d", topic, partitionID, cg.Name, lag) - if useTags != nil { + if *useTags { var tags []string tags = append(tags, "topic="+topic) tags = append(tags, fmt.Sprintf("partition=%d", partitionID))