class Datadog::Contrib::Kafka::Integration

Description of Kafka integration

Constants

MINIMUM_VERSION

Public Class Methods

compatible?() click to toggle source
Calls superclass method
# File lib/ddtrace/contrib/kafka/integration.rb, line 26
def self.compatible?
  super && version >= MINIMUM_VERSION
end
loaded?() click to toggle source
# File lib/ddtrace/contrib/kafka/integration.rb, line 21
def self.loaded?
  !defined?(::Kafka).nil? \
    && !defined?(::ActiveSupport::Notifications).nil?
end
version() click to toggle source
# File lib/ddtrace/contrib/kafka/integration.rb, line 17
def self.version
  Gem.loaded_specs['ruby-kafka'] && Gem.loaded_specs['ruby-kafka'].version
end

Public Instance Methods

default_configuration() click to toggle source
# File lib/ddtrace/contrib/kafka/integration.rb, line 30
def default_configuration
  Configuration::Settings.new
end
patcher() click to toggle source
# File lib/ddtrace/contrib/kafka/integration.rb, line 34
def patcher
  Patcher
end