lib/fluent/plugin/kafka_producer_ext.rb in fluent-plugin-kafka-0.13.1 vs lib/fluent/plugin/kafka_producer_ext.rb in fluent-plugin-kafka-0.14.0

@@ -248,10 +248,10 @@
       @pending_message_queue.each do |message|
         partition = message.partition
 
         begin
           if partition.nil?
-            partition = Partitioner.partition_for_key(partition_count, message)
+            partition = Partitioner.call(partition_count, message)
           end
 
           @buffer.write(
             value: message.value,
             key: message.key,