我目前正在做一个kafka流的poc，其中我尝试使用kakfa作为消息总线和数据库。我尝试ksql的第二个目的。我可以使用ksql查询主题，但是每次ksql都读取整个主题并在客户端对其进行过滤，这需要很长时间。有没有办法把整个主题具体化为Kafka的国库？
83qze16e1#
您可以将主题读取为ktable，并强制状态存储具体化通过交互式查询api访问内容。
StreamsBuilder builder = new StreamsBuilder(); KTable<Integer, Integer> table = builder.table( "topicName", Materialized.as("queryable-store-name"));
1条答案
按热度按时间83qze16e1#
您可以将主题读取为ktable，并强制状态存储具体化通过交互式查询api访问内容。