From 5f104265adeb1c3119a9fa52062d87954dc77317 Mon Sep 17 00:00:00 2001
From: mackjmr <mackenzie.jomard@datadoghq.com>
Date: Mon, 11 Dec 2023 18:50:40 +0100
Subject: [PATCH] source

---
 ci/values.yaml | 22 +++++++++++++++++++++-
 1 file changed, 21 insertions(+), 1 deletion(-)

diff --git a/ci/values.yaml b/ci/values.yaml
index 54c0c671b2a8..f8d3bf7155c0 100644
--- a/ci/values.yaml
+++ b/ci/values.yaml
@@ -110,6 +110,26 @@ config:
       - key: ddtags
         action: upsert
         value: "source:kafka"
+    attributes/producer:
+      include:
+        match_type: strict
+        attributes:
+          - key: "source"
+            value: 'orderproducer'
+      actions:
+      - key: ddtags
+        action: upsert
+        value: "source:kafka"
+    attributes/consumer:
+      include:
+        match_type: strict
+        attributes:
+          - key: "source"
+            value: 'frauddetectionservice'
+      actions:
+      - key: ddtags
+        action: upsert
+        value: "source:kafka"
     memory_limiter:
       check_interval: 1s
       limit_mib: 500
@@ -191,5 +211,5 @@ config:
         processors: [resourcedetection, k8sattributes, batch]
         exporters: [datadog]
       logs:
-        processors: [memory_limiter, resourcedetection, k8sattributes, batch, attributes, attributes/kafkasrc]
+        processors: [memory_limiter, resourcedetection, k8sattributes, batch, attributes, attributes/kafkasrc, attributes/producer, attributes/consumer]
         exporters: [datadog]