code: private void handleError(final String errorMessage) {
  		
  		failed = true;
  		
  		switch (errorPolicy) {
  		case LOG_ONLY:
  			logger.error(errorMessage);
  			break;
  			
  		case RUNTIME_EXCEPTION:
  			throw new RuntimeException(errorMessage);
  
  		default:
  			logger.error("Got error {} but unkown error policy {}", errorMessage, errorPolicy);
  			break;
  		}
  	}
docs: Handle the sequence number error
  @param errorMessage