Kafka Streams的事件源和物化视图
介绍
Kafka帮助您构建快速,高吞吐量,容错,可扩展的微服务和应用程序。 Kafka Streams将数据存储在Kafka集群(Kafka State Stores)中,并快速获取数据检票口。
该存储库通过Kafka Streaming演示了事件源(材料化视图)( )
在典型的生产环境中,我们有多个带有专用数据库的微服务,并且我们希望对每个数据库执行多阶段提交。
假设用户要在eShopping应用程序中下订单,我们可以使用不同的微服务来执行以下操作(a)检查所请求产品的库存(Inventory MicroService会处理此问题)(b)检查是否有任何付款方式可用并处理付款(由MicroService负责付款)(c)获取收货地址和帐单地址(由客户管理MicroService负责)
如果上述微服务中的任何一个发生故障,我们都希望回滚事务
1