Fix consumer offset to match java and not error in data-pipeline-edge

ericfirth · ericfirth · commit a350087e4e4f · 2025-11-19T15:48:14.000-05:00
diff --git a/lib/datadog/data_streams/processor.rb b/lib/datadog/data_streams/processor.rb
@@ -475,7 +475,7 @@ def serialize_consumer_backlogs
         @consumer_stats.map do |stat|
           {
             'Tags' => [
-              'type:kafka_consume',
+              'type:kafka_commit',
               "topic:#{stat[:topic]}",
               "partition:#{stat[:partition]}"
             ],

Original file line number	Diff line number	Diff line change
`@@ -475,7 +475,7 @@ def serialize_consumer_backlogs`
`475`	`475`	`@consumer_stats.map do \|stat\|`
`476`	`476`	`{`
`477`	`477`	`'Tags' => [`
`478`		`- 'type:kafka_consume',`
	`478`	`+ 'type:kafka_commit',`
`479`	`479`	`"topic:#{stat[:topic]}",`
`480`	`480`	`"partition:#{stat[:partition]}"`
`481`	`481`	`],`