lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb in opentelemetry-instrumentation-ruby_kafka-0.20.1 vs lib/opentelemetry/instrumentation/ruby_kafka/instrumentation.rb in opentelemetry-instrumentation-ruby_kafka-0.20.2

@@ -30,15 +30,17 @@
         def gem_version
           Gem::Version.new(Kafka::VERSION)
         end
 
         def require_patches
+          require_relative 'patches/async_producer'
           require_relative 'patches/producer'
           require_relative 'patches/consumer'
           require_relative 'patches/client'
         end
 
         def patch
+          ::Kafka::AsyncProducer.prepend(Patches::AsyncProducer)
           ::Kafka::Producer.prepend(Patches::Producer)
           ::Kafka::Consumer.prepend(Patches::Consumer)
           ::Kafka::Client.prepend(Patches::Client)
         end
       end