docs: @SuppressWarnings("unchecked")
      public <K, V> StatefulRedisClusterPubSubConnection<K, V> connectPubSub(RedisCodec<K, V> codec) {
  
          if (partitions == null) {
              initializePartitions();
          }
  
          return getConnection(connectClusterPubSubAsync(codec));
      }