我在kafka流中创建了一个物化视图,我找不到java代码片段来读取物化视图。
有没有人建议代码读取一个物化视图并创建一个hashmap(假设key是string,value是long)。
创建kafka物化视图“queryable store name”的一个示例片段是:
StreamsBuilder builder = new StreamsBuilder();
KTable<Integer, Integer> table = builder.table(
"topicName",
Materialized.as("queryable-store-name"));
暂无答案!
目前还没有任何答案,快来回答吧!