lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.16.1 vs lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.16.2

@@ -292,10 +292,10 @@
     end
 
     def consume
       offset = @next_offset
       @fetch_args[:offset] = offset
-      messages = @kafka.fetch_messages(@fetch_args)
+      messages = @kafka.fetch_messages(**@fetch_args)
 
       return if messages.size.zero?
 
       es = Fluent::MultiEventStream.new
       tag = @topic_entry.topic