jeff-zou/flink-connector-redis

能否支持下ssl 加密

Opened this issue · 0 comments

目前client初始化方式

RedisURI.Builder builder =
RedisURI.builder()
.withHost(singleConfig.getHost())
.withPort(singleConfig.getPort())
没有是否加密的接口, 我们的实际使用情况是需要开启这个就像

val uri = RedisURI.builder().withHost(endpoint) // .withPort(Integer.parseInt(port)) .withSsl(true) .build(); val clusterClient = RedisClusterClient.create(uri);

@jeff-zou