From a21143320a94060ac1bbd347a7bc41f318533f6a Mon Sep 17 00:00:00 2001 From: Florian Boucault Date: Sat, 18 May 2019 08:47:58 +0200 Subject: [PATCH] Removed old comment that does not apply anylonger --- mdata/notifierKafka/cfg.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/mdata/notifierKafka/cfg.go b/mdata/notifierKafka/cfg.go index 536c49a35c..f628246efb 100644 --- a/mdata/notifierKafka/cfg.go +++ b/mdata/notifierKafka/cfg.go @@ -124,8 +124,6 @@ func ConfigProcess(instance string) { partitionLogSize = make(map[int32]*stats.Gauge64) partitionLag = make(map[int32]*stats.Gauge64) - // when booting up, we will delay consuming metrics until we have - // caught up to these offsets. for _, part := range partitions { // metric cluster.notifier.kafka.partition.%d.offset is the current offset for the partition (%d) that we have consumed partitionOffset[part] = stats.NewGauge64(fmt.Sprintf("cluster.notifier.kafka.partition.%d.offset", part))