материализовать всю тему кафки в rocksdb

Question

В настоящее время я делаю POC потоков kafka, в котором я пытаюсь использовать kakfa как шину обмена сообщениями, а также базу данных.Я пытаюсь ksql для второй цели.Я могу запросить тему с помощью ksql, но это занимает много времени, так как ksql каждый раз читает всю тему и фильтрует ее на стороне клиента.Есть ли способ материализовать всю тему как государственный магазин в кафке?

Answer 1

Вы можете прочитать тему как KTable и заставить материализацию хранилища состояний получить доступ к контенту через API интерактивных запросов.

StreamsBuilder builder = new StreamsBuilder();
 KTable<Integer, Integer> table = builder.table(
   "topicName",
   Materialized.as("queryable-store-name"));