更新时间:2022-12-14 GMT+08:00

配置Pipeline

  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”的相关配置,具体配置请参见加密传输