Масштабирование доступа к хранилищу состояний Kafka Streams с помощью многопоточности ⇐ JAVA

[Anonymous]

Я работаю над приложением Kafka-Streams, которое обрабатывает пары ключ-значение в хранилище состояний. В настоящее время я просматриваю все хранилище, используя store.all() и стандартный цикл while. Однако этот подход становится медленным при работе с большими наборами данных (около 10 миллионов пар ключ-значение).
KeyValueIterator iterator = store.all();
while(iterator.hasNext()){
//Process iterator.next()
}
iterator.close()


Подробнее здесь: https://stackoverflow.com/questions/785 ... ithreading