Force lag to -1 when offset is equal to -1 ISSUES #14

sundy-li · Feb 26, 2019 · c2bacbc · c2bacbc
1 parent e603490
commit c2bacbc
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/monitor/importer.go b/monitor/importer.go
@@ -68,6 +68,9 @@ func (i *Importer) start() {
 					"offsize": entry.Offset,
 					"lag":     entry.Logsize - entry.Offset,
 				}
+				if entry.Offset < 0 {
+					fields["lag"] = -1
+				}
 
 				tm := time.Unix(msg.Timestamp/1000, 0)
 				pt, err := client.NewPoint("consumer_metrics", tags, fields, tm)