Как прослушивать уведомления о пространстве ключей кластера Redis в Java с помощью клиента jedis?

Я столкнулся с той же проблемой, уведомление Keyspace работает с перебоями (работает 6 или 7 раз из 10). Я читал, что нужно подписаться на все главные узлы, чтобы получать уведомления. Если это поможет, я вставил свой файл конфигурации ниже:

KeySpaceNotificationMessageListener keySpaceNotificationMessageListener;

    @Value("${spring.redis.cluster.nodes}")
    private String hostsAndPorts;

    @Bean
    JedisConnectionFactory jedisConnectionFactory(RedisClusterConfiguration redisClusterConfiguration)
    {
        return new JedisConnectionFactory(redisClusterConfiguration);
    }

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(keySpaceNotificationMessageListener);
    }


    @Bean(name = "cacheManager1")
    @Primary
    public RedisCacheManager redisCacheManager1()
    {
        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                .disableCachingNullValues()
                .entryTtl(Duration.ofMinutes(1))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(RedisSerializer.json()));

        redisCacheConfiguration.usePrefix();

        return RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(jedisConnectionFactory(redisClusterConfiguration()))
                .cacheDefaults(redisCacheConfiguration).build();

    }

    @Bean(name = "cacheManager2")
    public RedisCacheManager redisCacheManager2( JedisConnectionFactory jedisConnectionFactory)
    {
        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                .disableCachingNullValues()
                .entryTtl(Duration.ofDays(1))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(RedisSerializer.json()));

        redisCacheConfiguration.usePrefix();

        return RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(jedisConnectionFactory(redisClusterConfiguration()))
                .cacheDefaults(redisCacheConfiguration).build();

    }

    @Bean
    public RedisClusterConfiguration redisClusterConfiguration()
    {
        String [] redisHostAndPorts = hostsAndPorts.split(",");

        System.out.println(Arrays.toString(redisHostAndPorts));
        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(Arrays.asList(redisHostAndPorts));
        return redisClusterConfiguration;
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(jedisConnectionFactory(redisClusterConfiguration()));
        container.addMessageListener(messageListener(), new PatternTopic("__keyspace@*:*"));
        container.setTaskExecutor(Executors.newFixedThreadPool(4));
        return container;
    }

    public void setKeySpaceNotificationMessageListener(KeySpaceNotificationMessageListener keySpaceNotificationMessageListener)
    {
        this.keySpaceNotificationMessageListener = keySpaceNotificationMessageListener;
    }