Sha256: b2830ec724a8468034375c05a45ebb4ca641deb5c15a223281c3b99a466ce624
Contents?: true
Size: 541 Bytes
Versions: 35
Compression:
Stored size: 541 Bytes
Contents
# frozen_string_literal: true
require_relative '../patcher'
require_relative 'ext'
require_relative 'events'
module Datadog
module Tracing
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
end
Version data entries
35 entries across 35 versions & 2 rubygems