lib/kafka/async_producer.rb in ruby-kafka-1.1.0 vs lib/kafka/async_producer.rb in ruby-kafka-1.2.0

@@ -244,13 +244,13 @@
         @logger.pop_tags
       end
 
       private
 
-      def produce(*args)
+      def produce(value, **kwargs)
         retries = 0
         begin
-          @producer.produce(*args)
+          @producer.produce(value, **kwargs)
         rescue BufferOverflow => e
           deliver_messages
           if @max_retries == -1
             retry
           elsif retries < @max_retries