配置Pipeline

本章节适用于MRS 3.x及之后版本。

1. 配置文件。
   • nettyconnector.registerserver.topic.storage：设置NettySink的IP、端口及并发度信息在第三方注册服务器上的路径（必填），例如：

     nettyconnector.registerserver.topic.storage: /flink/nettyconnector

   • nettyconnector.sinkserver.port.range：设置NettySink的端口范围（必填），例如：

     nettyconnector.sinkserver.port.range: 28444-28843

   • nettyconnector.ssl.enabled：设置NettySink与NettySource之间通信是否SSL加密（默认为false），例如：

     nettyconnector.ssl.enabled: true

2. 安全认证配置。
   • Zookeeper的SASL认证，依赖“flink-conf.yaml”中有关HA的相关配置。
   • SSL的keystore、truststore、keystore password、truststore password以及password等也使用“flink-conf.yaml”的相关配置，具体配置请参见加密传输。