lib/rdkafka/config.rb in rdkafka-0.7.0 vs lib/rdkafka/config.rb in rdkafka-0.8.0.beta.1

@@ -210,13 +210,11 @@
       Rdkafka::Bindings.rd_kafka_set_log_queue(
         handle,
         Rdkafka::Bindings.rd_kafka_queue_get_main(handle)
       )
 
-      FFI::AutoPointer.new(
-        handle,
-        Rdkafka::Bindings.method(:rd_kafka_destroy)
-      )
+      # Return handle which should be closed using rd_kafka_destroy after usage.
+      handle
     end
   end
 
   # @private
   class Opaque