module Datadog::Contrib::Kafka::Events::ConsumerGroup::Heartbeat
Defines instrumentation for heartbeat.consumer.kafka event
Constants
- EVENT_NAME
Public Class Methods
process(span, _event, _id, payload)
click to toggle source
Calls superclass method
# File lib/ddtrace/contrib/kafka/events/consumer_group/heartbeat.rb, line 19 def self.process(span, _event, _id, payload) super if payload.key?(:topic_partitions) payload[:topic_partitions].each do |topic, partitions| span.set_tag("#{Ext::TAG_TOPIC_PARTITIONS}.#{topic}", partitions) end end end
Public Instance Methods
span_name()
click to toggle source
# File lib/ddtrace/contrib/kafka/events/consumer_group/heartbeat.rb, line 31 def span_name Ext::SPAN_CONSUMER_HEARTBEAT end