Sha256: c313361992fc3d15cada5e55dd8b4ea6ff4d720bd59ac59f7887a25e51a4c940

Contents?: true

Size: 298 Bytes

Versions: 16

Compression:

Stored size: 298 Bytes

Contents

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

16 entries across 16 versions & 2 rubygems

Version Path
ddtrace-0.51.1 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.51.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.50.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.49.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.48.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.47.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.46.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.45.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.44.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.43.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.42.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.41.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ls-trace-0.2.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.40.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.39.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb
ddtrace-0.38.0 lib/ddtrace/contrib/kafka/consumer_group_event.rb