consumer_spec.rb in rdkafka-0.12.0.beta.1

- old
+ new

@@ -239,11 +239,11 @@
       expect(assignment.to_h["consume_test_topic"].length).to eq 3
     end
 
     it "should return the assignment when subscribed" do
       # Make sure there's a message
-      report = producer.produce(
+      producer.produce(
         topic:     "consume_test_topic",
         payload:   "payload 1",
         key:       "key 1",
         partition: 0
       ).wait
@@ -270,11 +270,11 @@
 
   describe "#close" do
     it "should close a consumer" do
       consumer.subscribe("consume_test_topic")
       100.times do |i|
-        report = producer.produce(
+        producer.produce(
           topic:     "consume_test_topic",
           payload:   "payload #{i}",
           key:       "key #{i}",
           partition: 0
         ).wait
@@ -287,11 +287,11 @@
   end
 
   describe "#commit, #committed and #store_offset" do
     # Make sure there's a stored offset
     let!(:report) do
-      report = producer.produce(
+      producer.produce(
         topic:     "consume_test_topic",
         payload:   "payload 1",
         key:       "key 1",
         partition: 0
       ).wait
@@ -829,11 +829,10 @@
             :"enable.auto.offset.store" => false
           }
         )
         consumer = config.consumer
         consumer.subscribe(topic_name)
-        loop_count = 0
         batches_yielded = []
         exceptions_yielded = []
         each_batch_iterations = 0
         poll_count = 0
         expect(consumer)
@@ -873,10 +872,9 @@
             :"enable.auto.offset.store" => false
           }
         )
         consumer = config.consumer
         consumer.subscribe(topic_name)
-        loop_count = 0
         batches_yielded = []
         exceptions_yielded = []
         each_batch_iterations = 0
         poll_count = 0
         expect(consumer)