Как читать материализованное представление, созданное в кафке через код Java - PullRequest
0 голосов
/ 18 мая 2018

Я создал материализованное представление в потоке kafka, я не могу найти фрагмент кода Java для чтения материализованного представления.

Может ли кто-нибудь предложить код для чтения материализованного представления и создания HashMap (при условии, что ключ - String, а значение - Long).

Один пример фрагмента для создания материализованного представления kafka "queryable-store-name":

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