lib/racecar/consumer.rb in racecar-2.0.0.alpha1 vs lib/racecar/consumer.rb in racecar-2.0.0.alpha2

@@ -28,11 +28,11 @@
           subscriptions << Subscription.new(topic, start_from_beginning, max_bytes_per_partition, additional_config)
         end
       end
     end
 
-    def configure(producer:, consumer:, instrumenter:)
+    def configure(producer:, consumer:, instrumenter: NullInstrumenter)
       @producer = producer
       @consumer = consumer
       @instrumenter = instrumenter
     end
 
@@ -46,10 +46,10 @@
     end
 
     protected
 
     # https://github.com/appsignal/rdkafka-ruby#producing-messages
-    def produce(topic:, payload:, key:, headers: nil)
+    def produce(payload, topic:, key:, headers: nil)
       @delivery_handles ||= []
 
       extra_info = {
         value:       payload,
         key:         key,