Contents

# typed: true

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

            span.set_tag(Ext::TAG_GROUP, payload[:group_id])
            span.set_tag(Tracing::Metadata::Ext::TAG_KIND, Tracing::Metadata::Ext::SpanKind::TAG_CONSUMER)
          end
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ddtrace-1.9.0	lib/datadog/tracing/contrib/kafka/consumer_event.rb
ddtrace-1.8.0	lib/datadog/tracing/contrib/kafka/consumer_event.rb
ddtrace-1.7.0	lib/datadog/tracing/contrib/kafka/consumer_event.rb