Sha256: d9a99597a52933b6172503e8d659bb33e86a0a3d4966bccfaad806cb3a007fe2
Contents?: true
Size: 361 Bytes
Versions: 13
Compression:
Stored size: 361 Bytes
Contents
# typed: true
module Datadog
module Tracing
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
end
Version data entries
13 entries across 13 versions & 1 rubygems