Contents

module Datadog
  module Tracing
    module Contrib
      module Kafka
        # Defines basic behaviors for an event for a consumer group.
        module ConsumerGroupEvent
          def process(span, _event, _id, payload)
            super

            span.resource = payload[:group_id]
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ddtrace-1.10.1	lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
ddtrace-1.10.0	lib/datadog/tracing/contrib/kafka/consumer_group_event.rb