lib/racecar/consumer_set.rb in racecar-2.3.0 vs lib/racecar/consumer_set.rb in racecar-2.3.1

@@ -154,10 +154,10 @@
     # polls a message for the current consumer, handling any API edge cases.
     def poll_current_consumer(max_wait_time_ms)
       msg = current.poll(max_wait_time_ms)
     rescue Rdkafka::RdkafkaError => e
       case e.code
-      when :max_poll_exceeded, :transport # -147, -195
+      when :max_poll_exceeded, :transport, :not_coordinator # -147, -195, 16
         reset_current_consumer
       end
       raise
     ensure
       @last_poll_read_nil_message = msg.nil?