lib/racecar/consumer_set.rb in racecar-2.0.0.alpha2 vs lib/racecar/consumer_set.rb in racecar-2.0.0.alpha3

@@ -13,16 +13,17 @@
     def poll(timeout_ms)
       maybe_select_next_consumer
       retried ||= false
       msg = current.poll(timeout_ms)
     rescue Rdkafka::RdkafkaError => e
+      raise if retried
+      retried = true
+
       @logger.error "Error for topic subscription #{current_subscription}: #{e}"
 
       case e.code
-      when :max_poll_exceeded
+      when :max_poll_exceeded, :transport # -147, -195
         reset_current_consumer
-        raise if retried
-        retried = true
         retry
       else
         raise
       end
     ensure