Хранилище состояний Kafka пусто, а метод metadataForKey возвращает текущий экземпляр для необходимого ключа - PullRequest
0 голосов
/ 26 марта 2019

У меня есть несколько экземпляров потокового приложения Kafka.Чтобы запросить ключ из магазина, я вызвал streams.metadataForKey с необходимым ключом.Этот метод возвращает сведения об экземпляре для магазина успешно.Но когда я запрашиваю магазин в этом случае, я получаю ноль.store.get(key) returns null Infact размер магазина был 0.

store.approximateNumEntries() returns 0

streams.metadataForKey(...) говорит, что экземпляр содержит ключ.

Я не понимаю, почемуданные отсутствуют в магазине.

...