查询Kafka物化视图效率答案

【问题标题】：Query Kafka materialized views efficiency查询Kafka物化视图效率
【发布时间】：2022-06-16 20:46:30
【问题描述】：

我想创建一个使用物化视图而不是传统数据库的可扩展分布式应用程序。

您能否告诉我物化 get 的视图与按 id 的 SELECT 视图相比效率如何？恐怕使用 REST 的不同实例之间的这种“跳跃”会大大降低它们的速度。

org.apache.kafka.streams.state.HostInfo hostInfo = interactiveQueryService.getHostInfo("store-name",
                        key, keySerializer);

if (interactiveQueryService.getCurrentHostInfo().equals(hostInfo)) {

    //query from the store that is locally available
}
else {
    //query from the remote host
}

这有多可靠？如何区分缺少元素和不成功的“跳跃”？

【问题讨论】：

我认为您必须在您的环境中进行尝试才能获得准确/有用的数字。通常，大多数分布式键值系统都需要某种查找来了解哪台机器托管了一个键。鉴于此，我认为您通常会承担一些此类开销。（我没有看到很好的解决方法。）

标签： apache-kafka-streams materialized-views

【解决方案1】：

在 Apache Kafka Streams 的实际版本（目前最高 3.0）中，每次流组重新分区时交互式查询都不可用。离线查询的这一功能正在积压中。

那我暂时不建议使用这个策略。

【讨论】：