如果redis带有认证的密码org/apache/rocketmq/connect/redis/common/Config.java里面getRedisUri()方法需要加上sb.append(":").append(redisPassword).append("@");认证否则认证不通过，redis.replicator.version 的版本好像有点过低，只支持redis6 <img width="508" height="523" alt="Image" src="https://github.com/user-attachments/assets/c1857547-ec59-41d2-90de-5c4ed5e5fad8" />
如果redis带有认证的密码org/apache/rocketmq/connect/redis/common/Config.java里面getRedisUri()方法需要加上sb.append(":").append(redisPassword).append("@");认证否则认证不通过，redis.replicator.version 的版本好像有点过低，只支持redis6