Xiaoxiao Chen
Results
1
issues of
Xiaoxiao Chen
目前client初始化方式 https://github.com/jeff-zou/flink-connector-redis/blob/6ac8f3b208faa9c0f123ae2837ccf3d5d85e94b3/src/main/java/org/apache/flink/streaming/connectors/redis/container/RedisClientBuilder.java#L91-L94 没有是否加密的接口, 我们的实际使用情况是需要开启这个就像 `val uri = RedisURI.builder().withHost(endpoint) // .withPort(Integer.parseInt(port)) .withSsl(true) .build(); val clusterClient = RedisClusterClient.create(uri);` @jeff-zou