Contents

# typed: true

require 'datadog/tracing/contrib/kafka/ext'
require 'datadog/tracing/contrib/kafka/event'
require 'datadog/tracing/contrib/kafka/consumer_event'
require 'datadog/tracing/contrib/kafka/consumer_group_event'

module Datadog
  module Tracing
    module Contrib
      module Kafka
        module Events
          module ConsumerGroup
            # Defines instrumentation for sync_group.consumer.kafka event
            module SyncGroup
              include Kafka::Event
              extend Kafka::ConsumerEvent
              extend Kafka::ConsumerGroupEvent

              EVENT_NAME = 'sync_group.consumer.kafka'.freeze

              module_function

              def span_name
                Ext::SPAN_CONSUMER_SYNC_GROUP
              end

              def span_options
                super.merge({ tags: { Tracing::Metadata::Ext::TAG_OPERATION => Ext::TAG_OPERATION_CONSUMER_SYNC_GROUP } })
              end
            end
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ddtrace-1.2.0	lib/datadog/tracing/contrib/kafka/events/consumer_group/sync_group.rb
ddtrace-1.1.0	lib/datadog/tracing/contrib/kafka/events/consumer_group/sync_group.rb
ddtrace-1.0.0	lib/datadog/tracing/contrib/kafka/events/consumer_group/sync_group.rb
ddtrace-1.0.0.beta2	lib/datadog/tracing/contrib/kafka/events/consumer_group/sync_group.rb