docs: @Override
      public int transfer(Long maxTaskId, long oldPartitionId) throws Exception {
  
          try {
              return _pe.transfer(maxTaskId, oldPartitionId);
          } catch (Exception e) {
              throw buildAndLogException(e);
          }
      }