Fix max_wait_time usage

lib/racecar/config.rb

@@ -156,6 +156,10 @@ class Config < KingKonf::Config
 
     attr_accessor :subscriptions, :logger
 
+    def max_wait_time_ms
+      max_wait_time * 1000
+    end
+
     def initialize(env: ENV)
       super(env: env)
       @error_handler = proc {}

lib/racecar/consumer_set.rb

@@ -176,7 +176,7 @@ def rdkafka_config(subscription)
         "fetch.max.bytes"         => @config.max_bytes,
         "message.max.bytes"       => subscription.max_bytes_per_partition,
         "fetch.min.bytes"         => @config.fetch_min_bytes,
-        "fetch.wait.max.ms"       => @config.max_wait_time * 1000,
+        "fetch.wait.max.ms"       => @config.max_wait_time_ms,
         "group.id"                => @config.group_id,
         "heartbeat.interval.ms"   => @config.heartbeat_interval * 1000,
         "max.poll.interval.ms"    => @config.max_poll_interval * 1000,

lib/racecar/runner.rb

@@ -65,12 +65,12 @@ def run
         @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

spec/config_spec.rb

@@ -123,6 +123,14 @@
     end
   end
 
+  describe '#max_wait_time_ms' do
+    before { config.max_wait_time = 12 }
+
+    it 'returns max_wait_time in milliseconds' do
+      expect(config.max_wait_time_ms).to eq(12_000)
+    end
+  end
+
   describe "#validate!" do
     before do
       config.brokers = ["a"]