Module: Datadog::Tracing::Contrib::Kafka::ConsumerEvent
- Included in:
- Events::Consumer::ProcessBatch, Events::Consumer::ProcessMessage, Events::ConsumerGroup::Heartbeat, Events::ConsumerGroup::JoinGroup, Events::ConsumerGroup::LeaveGroup, Events::ConsumerGroup::SyncGroup
- Defined in:
- lib/datadog/tracing/contrib/kafka/consumer_event.rb
Overview
Defines basic behaviors for an event for a consumer.
Instance Method Summary collapse
Instance Method Details
#process(span, _event, _id, payload) ⇒ Object
9 10 11 12 13 14 |
# File 'lib/datadog/tracing/contrib/kafka/consumer_event.rb', line 9 def process(span, _event, _id, payload) super span.set_tag(Ext::TAG_GROUP, payload[:group_id]) span.set_tag(Tracing::Metadata::Ext::TAG_KIND, Tracing::Metadata::Ext::SpanKind::TAG_CONSUMER) end |