class OpenTelemetry::Instrumentation::RubyKafka::Instrumentation

The Instrumentation class contains logic to detect and install the KafkaRuby instrumentation

Constants

MINIMUM_VERSION

Private Instance Methods

gem_version() click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 30
def gem_version
  Gem.loaded_specs['ruby-kafka']&.version || Gem::Version.new(Kafka::VERSION)
end
patch() click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 40
def patch
  ::Kafka::Producer.prepend(Patches::Producer)
  ::Kafka::Consumer.prepend(Patches::Consumer)
  ::Kafka::Client.prepend(Patches::Client)
end
require_patches() click to toggle source
# File lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb, line 34
def require_patches
  require_relative 'patches/producer'
  require_relative 'patches/consumer'
  require_relative 'patches/client'
end