Sha256: f2fb4c477dc3e58b420f85a3973a2d2b80f31435111d5acf8996d99fc9765c4d
Contents?: true
Size: 374 Bytes
Versions: 26
Compression:
Stored size: 374 Bytes
Contents
# frozen_string_literal: true
module Datadog
module Tracing
module Contrib
module Kafka
# Defines basic behaviors for an event for a consumer group.
module ConsumerGroupEvent
def process(span, _event, _id, payload)
super
span.resource = payload[:group_id]
end
end
end
end
end
end
Version data entries
26 entries across 26 versions & 2 rubygems