Sha256: e2b133ae87d83cff36b7b5f6a6678240bd3dadd9f146df9746bede7f119bf67f

Contents?: true

Size: 312 Bytes

Versions: 5

Compression:

Stored size: 312 Bytes

Contents

# typed: true
module Datadog
  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

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
ddtrace-0.54.2 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.54.1 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.54.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.53.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.52.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb