lib/racecar/runner.rb in racecar-0.1.4 vs lib/racecar/runner.rb in racecar-0.2.0

@@ -27,13 +27,14 @@
       # Stop the consumer on SIGINT and SIGQUIT.
       trap("QUIT") { consumer.stop }
       trap("INT") { consumer.stop }
 
       config.subscriptions.each do |subscription|
-        topic = subscription.topic
-        start_from_beginning = subscription.start_from_beginning
-
-        consumer.subscribe(topic, start_from_beginning: start_from_beginning)
+        consumer.subscribe(
+          subscription.topic,
+          start_from_beginning: subscription.start_from_beginning,
+          max_bytes_per_partition: subscription.max_bytes_per_partition,
+        )
       end
 
       begin
         consumer.each_message(max_wait_time: config.max_wait_time) do |message|
           processor.process(message)