Kafka Streams物化是如何工作的



问题1:我读到Kafka Streams的所有有状态操作(例如Aggregate、Count等(都在客户端实例上创建了一个状态存储。当我们将Materialized.with或Materialized.as与有状态操作一起使用时,有什么区别。它只用于交互式查询吗?或者,当我们只调用有状态操作与使用Materialized视图调用有状态运算时,内部还会发生其他事情吗?

问题2:当num.standbyreplicas>0时,内部会发生什么?是复制了变更日志主题,还是只复制了状态存储?复制副本如何获取更改?复制是如何进行的?

当我们将Materialized.with或Materialized.as与有状态操作一起使用时,有什么区别。

Materializes.as()设置一个存储名称,从而使存储能够进行交互式查询。它还会影响底层变更日志主题的名称,因此不应为已部署的应用程序更改它。除此之外,没有什么区别。

当num.standbyreplicas>0时,内部会发生什么?是复制了变更日志主题,还是只复制了状态存储?

基于代理/主题配置replication.factor复制变更日志主题。备用任务的数量与变更日志主题复制无关,而仅适用于客户端状态存储复制。备用任务,读取活动任务写入的变更日志主题以保持复制状态。

相关内容

  • 没有找到相关文章

最新更新