Removed old comment that does not apply anylonger

grafana · May 18, 2019 · a211433 · a211433
1 parent c451e62
commit a211433
Showing 1 changed file with 0 additions and 2 deletions.
diff --git 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))