You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: with_branching_logic_on_retry_spec.rb
    path of file: ./repos/karafka/spec/integrations/consumption
    
    the code of the file until where you have to start completion: # frozen_string_literal: true

# We should be able to apply custom logic flow, when re-processing data after an er
    
  def consume
    messages.each do |message|
      raise SuperStandardError if message.offset == 5 && !retrying?

      DT[:offsets] << message.offset

      mark_as_consumed(message)
    end
  end