diff --git a/internal/db/kvs/redis/redis.go b/internal/db/kvs/redis/redis.go
index 85dc8c79d9..eabd97e850 100644
--- a/internal/db/kvs/redis/redis.go
+++ b/internal/db/kvs/redis/redis.go
@@ -230,13 +230,6 @@ func (rc *redisClient) newClusterClient(ctx context.Context) (c *redis.ClusterCl
 	} else {
 		c = redis.NewClusterClient(&redis.ClusterOptions{
 			Addrs: rc.addrs,
-			NewClient: func(opt *redis.Options) *redis.Client {
-				c, err := rc.newClient(ctx)
-				if err != nil {
-					return redis.NewClient(opt)
-				}
-				return c
-			},
 			Dialer:             rc.dialerFunc,
 			MaxRedirects:       rc.maxRedirects,
 			ReadOnly:           rc.readOnly,