Расширение клиента Quarkus Redis не получает все сообщения о ключевых событиях с истекшим сроком действия ⇐ JAVA

[Anonymous]

У меня есть кластер Redis с 6 узлами, развернутыми в моей среде K8S. Среда развертывания может находиться на GKE или частном облаке в OpenShift. < /P>
развернутое приложение Quarkus с использованием расширения клиента Redis. Я использую ReactiveredIsDataSource для регистрации для подписки на срок действия ключевых событий, например, ReactivePubSubCommands. Я использую мятеж для реактивной обработки этих событий. Здесь есть известная проблема? Нужно ли мне явно зарегистрироваться против каждого хоста в кластере? Что работает, когда прибудет сообщение. < /p>

Код: Выделить всё

    private void subscribe() {
pubSubCommands.subscribeToPatterns(pushConfig.keyPattern())
.select()
.where(msg -> msgPattern.matcher(msg).matches())
.onItem()
.invoke(expiredCacheKVCallback::expiredMessageKey)
.onFailure()
.invoke(err -> {
logger.error("Valkey subscription error. Attempting to reconnect...", err);
scheduleReconnect();
})
.subscribe()
.with(msg -> logger.infof("New message has been processed %s.", msg),
err -> logger.error("Error while listening for new events from the cache ", err));
}

Любые предложения по подсказку оцениваются

Подробнее здесь: https://stackoverflow.com/questions/794 ... t-messages