Sha256: aef0db03367d682b60221696ab67b53c3789b75d0f38ed33bfaebc0640675207
Contents?: true
Size: 485 Bytes
Versions: 6
Compression:
Stored size: 485 Bytes
Contents
# frozen_string_literal: true
module Datadog
module Tracing
module Contrib
module Kafka
# Defines basic behaviors for an event for a consumer.
module ConsumerEvent
def on_start(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
end
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems