Sha256: 3a8aa254bb90d2e37ac2f11af88def675a91562d81250beda29dc31ad174258d
Contents?: true
Size: 910 Bytes
Versions: 5
Compression:
Stored size: 910 Bytes
Contents
# typed: false require 'ddtrace/contrib/integration' require 'ddtrace/contrib/kafka/configuration/settings' require 'ddtrace/contrib/kafka/patcher' module Datadog module Contrib module Kafka # Description of Kafka integration class Integration include Contrib::Integration MINIMUM_VERSION = Gem::Version.new('0.7.10') register_as :kafka, auto_patch: false def self.version Gem.loaded_specs['ruby-kafka'] && Gem.loaded_specs['ruby-kafka'].version end def self.loaded? !defined?(::Kafka).nil? \ && !defined?(::ActiveSupport::Notifications).nil? end def self.compatible? super && version >= MINIMUM_VERSION end def default_configuration Configuration::Settings.new end def patcher Patcher end end end end end
Version data entries
5 entries across 5 versions & 1 rubygems