def mark_as_consumed(message)
          # seek offset can be nil only in case `#seek` was invoked with offset reset request
          # In case like this we ignore marking
          return true if coordinator.seek_offset.nil?
          # Ignore earlier offsets than the one we already committed