Sha256: e929c9ba3d7ce0a125f3623bc287d32fecf7caa59da65fa79643ca70322f0fda
Contents?: true
Size: 315 Bytes
Versions: 5
Compression:
Stored size: 315 Bytes
Contents
# typed: true
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
5 entries across 5 versions & 1 rubygems