Sha256: 1796bf61cc042902fe85f86923d78602e30977003ee1f34448c9715ed724a712

Contents?: true

Size: 375 Bytes

Versions: 14

Compression:

Stored size: 375 Bytes

Contents

# frozen_string_literal: true

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

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

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
datadog-2.12.2 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.12.1 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.12.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.11.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.10.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.9.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.8.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.7.1 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.7.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.6.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.5.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.4.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.3.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb
datadog-2.2.0 lib/datadog/tracing/contrib/kafka/consumer_group_event.rb