lib/kafka/datadog.rb in ruby-kafka-0.3.9 vs lib/kafka/datadog.rb in ruby-kafka-0.3.10

@@ -91,10 +91,11 @@
       def process_message(event)
         lag = event.payload.fetch(:offset_lag)
 
         tags = {
           client: event.payload.fetch(:client_id),
+          group_id: event.payload.fetch(:group_id),
           topic: event.payload.fetch(:topic),
           partition: event.payload.fetch(:partition),
         }
 
         if event.payload.key?(:exception)
@@ -110,9 +111,10 @@
       def process_batch(event)
         messages = event.payload.fetch(:message_count)
 
         tags = {
           client: event.payload.fetch(:client_id),
+          group_id: event.payload.fetch(:group_id),
           topic: event.payload.fetch(:topic),
           partition: event.payload.fetch(:partition),
         }
 
         if event.payload.key?(:exception)