lib/racecar/consumer_set.rb in racecar-2.8.0.rc.1 vs lib/racecar/consumer_set.rb in racecar-2.8.1

@@ -47,9 +47,12 @@
       messages
     end
 
     def store_offset(message)
       current.store_offset(message)
+    rescue Rdkafka::RdkafkaError => e
+      raise ErroneousStateError.new(e) if e.code == :state # -172
+      raise e
     end
 
     def commit
       each_subscribed do |consumer|
         commit_rescue_no_offset(consumer)