Removing certain Datadog tags (#718)

artie-labs · Jun 12, 2024 · 2539f85 · 2539f85
1 parent c536497
commit 2539f85
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 13 deletions.
diff --git a/lib/artie/message.go b/lib/artie/message.go
@@ -74,22 +74,22 @@ func (m *Message) EmitRowLag(metricsClient base.Client, mode config.Mode, groupI
 		return
 	}
 
-	metricsClient.GaugeWithSample("row.lag", float64(m.KafkaMsg.HighWaterMark-m.KafkaMsg.Offset), map[string]string{
-		"mode":      mode.String(),
-		"groupID":   groupID,
-		"topic":     m.Topic(),
-		"table":     table,
-		"partition": m.Partition(),
-	}, 0.5)
+	metricsClient.GaugeWithSample(
+		"row.lag",
+		float64(m.KafkaMsg.HighWaterMark-m.KafkaMsg.Offset),
+		map[string]string{
+			"mode":    mode.String(),
+			"groupID": groupID,
+			"table":   table,
+		},
+		0.5)
 }
 
 func (m *Message) EmitIngestionLag(metricsClient base.Client, mode config.Mode, groupID, table string) {
 	metricsClient.Timing("ingestion.lag", time.Since(m.PublishTime()), map[string]string{
-		"mode":      mode.String(),
-		"groupID":   groupID,
-		"topic":     m.Topic(),
-		"table":     table,
-		"partition": m.Partition(),
+		"mode":    mode.String(),
+		"groupID": groupID,
+		"table":   table,
 	})
 }
 

diff --git a/processes/consumer/process.go b/processes/consumer/process.go
@@ -27,7 +27,6 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo
 	tags := map[string]string{
 		"mode":    cfg.Mode.String(),
 		"groupID": p.GroupID,
-		"topic":   p.Msg.Topic(),
 		"what":    "success",
 	}