Open Sunninsky opened 3 months ago
目前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
目前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