lib/racecar/consumer_set.rb in racecar-2.8.1 vs lib/racecar/consumer_set.rb in racecar-2.8.2.beta

@@ -48,10 +48,13 @@
     end
 
     def store_offset(message)
       current.store_offset(message)
     rescue Rdkafka::RdkafkaError => e
-      raise ErroneousStateError.new(e) if e.code == :state # -172
+      if e.code == :state # -172
+        @logger.warn "Attempted to store_offset, but we're not subscribed to it: #{ErroneousStateError.new(e)}"
+        return
+      end
       raise e
     end
 
     def commit
       each_subscribed do |consumer|