lib/racecar/runner.rb in racecar-2.0.0.beta5 vs lib/racecar/runner.rb in racecar-2.0.0.beta6

@@ -63,15 +63,15 @@
         break if @stop_requested
         resume_paused_partitions
         @instrumenter.instrument("main_loop", instrumentation_payload) do
           case process_method
           when :batch then
-            msg_per_part = consumer.batch_poll(config.max_wait_time).group_by(&:partition)
+            msg_per_part = consumer.batch_poll(config.max_wait_time_ms).group_by(&:partition)
             msg_per_part.each_value do |messages|
               process_batch(messages)
             end
           when :single then
-            message = consumer.poll(config.max_wait_time)
+            message = consumer.poll(config.max_wait_time_ms)
             process(message) if message
           end
         end
       end