Sha256: 9f74dcaf403545c9fd1ba5b1525b0e610cf7c71a496936355dc158304aed303c
Contents?: true
Size: 301 Bytes
Versions: 16
Compression:
Stored size: 301 Bytes
Contents
module Datadog
module Contrib
module Kafka
# Defines basic behaviors for an event for a consumer.
module ConsumerEvent
def process(span, _event, _id, payload)
super
span.set_tag(Ext::TAG_GROUP, payload[:group_id])
end
end
end
end
end
Version data entries
16 entries across 16 versions & 2 rubygems