public static PipeSubscribeHandshakeReq toTPipeSubscribeReq(final ConsumerConfig consumerConfig)
      throws IOException {
    final PipeSubscribeHandshakeReq req = new PipeSubscribeHandshakeReq();

    req.consumerConfig = consumerConfig;

    req.version = PipeSubscribeRequestVersion.VERSION_1.getVersion();
    req.type = PipeSubscribeRequestType.HANDSHAKE.getType();
    req.body = ConsumerConfig.serialize(consumerConfig);

    return req;
  }
Serialize the incoming parameters into `PipeSubscribeHandshakeReq`, called by the subscription
client.
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHandshakeReq.java