lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb in opentelemetry-instrumentation-ruby_kafka-0.18.2 vs lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb in opentelemetry-instrumentation-ruby_kafka-0.18.3

@@ -20,16 +20,16 @@
         present do
           !defined?(::Kafka).nil?
         end
 
         compatible do
-          gem_version >= MINIMUM_VERSION
+          (!gem_version.nil? && gem_version >= MINIMUM_VERSION)
         end
 
         private
 
         def gem_version
-          Gem.loaded_specs['ruby-kafka'].version
+          Gem.loaded_specs['ruby-kafka']&.version || Gem::Version.new(Kafka::VERSION)
         end
 
         def require_patches
           require_relative 'patches/producer'
           require_relative 'patches/consumer'