From 2539f8591e109bb4f29f756b8f261f783a4d4b39 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Wed, 12 Jun 2024 16:33:49 -0700
Subject: [PATCH] Removing certain Datadog tags (#718)

---
 lib/artie/message.go          | 24 ++++++++++++------------
 processes/consumer/process.go |  1 -
 2 files changed, 12 insertions(+), 13 deletions(-)

diff --git a/lib/artie/message.go b/lib/artie/message.go
index ccecffb32..ef8f3716f 100644
--- 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
index 8e30a303b..2e37945d6 100644
--- 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",
 	}