lib/fluent/plugin/out_rdkafka.rb in fluent-plugin-kafka-0.11.2 vs lib/fluent/plugin/out_rdkafka.rb in fluent-plugin-kafka-0.12.0

@@ -266,10 +266,10 @@
 
         producer = get_producer
         handler = enqueue_with_retry(producer, topic, record_buf, message_key, partition)
         handler
       }.each { |handler|
-        handler.wait(@rdkafka_delivery_handle_poll_timeout) if @rdkafka_delivery_handle_poll_timeout != 0
+        handler.wait(max_wait_timeout: @rdkafka_delivery_handle_poll_timeout) if @rdkafka_delivery_handle_poll_timeout != 0
       }
     end
   rescue Exception => e
     log.warn "Send exception occurred: #{e} at #{e.backtrace.first}"
     # Raise exception to retry sendind messages