docs: private void markUsed(EtlEventData data) throws ZkNoNodeException, ZkException {
          String path = StagePathUtils.getProcess(data.getPipelineId(), data.getProcessId());
          // 序列化
          ProcessNodeEventData eventData = new ProcessNodeEventData();
          Long nid = ArbitrateConfigUtils.getCurrentNid();
          eventData.setNid(nid);
          eventData.setStatus(ProcessNodeEventData.Status.USED);// 标记为已使用
          eventData.setMode(ArbitrateMode.RPC);// 直接声明为rpc模式
          byte[] bytes = JsonUtils.marshalToByte(eventData);
          zookeeper.writeData(path, bytes);
      }