Sha256: e1e61950b7c3bed78ef923d3363b3471e5ea20cd7c5d2d7c7feddc84cc2ee1ef
Contents?: true
Size: 531 Bytes
Versions: 5
Compression:
Stored size: 531 Bytes
Contents
# typed: true
require 'ddtrace/contrib/patcher'
require 'ddtrace/ext/app_types'
require 'ddtrace/contrib/kafka/ext'
require 'ddtrace/contrib/kafka/events'
module Datadog
module Contrib
module Kafka
# Patcher enables patching of 'kafka' module.
module Patcher
include Contrib::Patcher
module_function
def target_version
Integration.version
end
def patch
# Subscribe to Kafka events
Events.subscribe!
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems