В документе kafka сказано, что мы можем запросить хранилище состояний через RPC. Поэтому я не уверен, что QueryableStoreRegistry может получить такую же функциональность в весеннем облачном потоке.
Это область, в которой мы ожидаем улучшения в следующей версии механизма связывания Spring Cloud Stream.Пожалуйста, смотрите этот выпуск .