KafkaStream-CQRS-EventSourcing:Kafka Streams的事件源（CQRS）和实例化视图-源码
Kafka Streams的事件源和物化视图
介绍
Kafka帮助您构建快速，高吞吐量，容错，可扩展的微服务和应用程序。 Kafka Streams将数据存储在Kafka集群（Kafka State Stores）中，并快速获取数据检票口。
该存储库通过Kafka Streaming演示了事件源（材料化视图）（ ）
在典型的生产环境中，我们有多个带有专用数据库的微服务，并且我们希望对每个数据库执行多阶段提交。
假设用户要在eShopping应用程序中下订单，我们可以使用不同的微服务来执行以下操作（a）检查所请求产品的库存（Inventory MicroService会处理此问题）（b）检查是否有任何付款方式可用并处理付款（由MicroService负责付款）（c）获取收货地址和帐单地址（由客户管理MicroService负责）
如果上述微服务中的任何一个发生故障，我们都希望回滚事务
文件下载
资源详情
[{"title":"（ 62 个子文件 191KB ） KafkaStream-CQRS-EventSourcing:Kafka Streams的事件源（CQRS）和实例化视图-源码","children":[{"title":"KafkaStream-CQRS-EventSourcing-master","children":[{"title":".github","children":[{"title":"ISSUE_TEMPLATE","children":[{"title":"bug_report.md <span style='color:#111;'> 834B </span>","children":null,"spread":false},{"title":"custom.md <span style='color:#111;'> 126B </span>","children":null,"spread":false},{"title":"feature_request.md <span style='color:#111;'> 595B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"mvnw.cmd <span style='color:#111;'> 4.88KB </span>","children":null,"spread":false},{"title":"mvnw <span style='color:#111;'> 6.32KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"kafkastream","children":[{"title":"jersey","children":[{"title":"Calculator.java <span style='color:#111;'> 963B </span>","children":null,"spread":false},{"title":"JettyRESTServer.java <span style='color:#111;'> 1.22KB </span>","children":null,"spread":false}],"spread":true},{"title":"TestEventsListener.java <span style='color:#111;'> 7.87KB </span>","children":null,"spread":false},{"title":"TestProducer.java <span style='color:#111;'> 6.46KB </span>","children":null,"spread":false},{"title":"KafkaConsumerTestEventsListner.java <span style='color:#111;'> 1.65KB </span>","children":null,"spread":false},{"title":"TestConsumer.java <span style='color:#111;'> 19.69KB </span>","children":null,"spread":false},{"title":"KafkaStreamApplicationTests.java <span style='color:#111;'> 384B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"others","children":[{"title":"confluent_schema_commands.md <span style='color:#111;'> 3.26KB </span>","children":null,"spread":false},{"title":"Schemas.json <span style='color:#111;'> 2.14KB </span>","children":null,"spread":false}],"spread":true},{"title":"avro","children":[{"title":"Customer.avsc <span style='color:#111;'> 317B </span>","children":null,"spread":false},{"title":"Greetings.avsc <span style='color:#111;'> 189B </span>","children":null,"spread":false},{"title":"Order.avsc <span style='color:#111;'> 334B </span>","children":null,"spread":false},{"title":"CustomerOrder.avsc <span style='color:#111;'> 513B </span>","children":null,"spread":false}],"spread":true},{"title":"templates","children":[{"title":"customers.html <span style='color:#111;'> 1.67KB </span>","children":null,"spread":false},{"title":"greetings.html <span style='color:#111;'> 1.26KB </span>","children":null,"spread":false},{"title":"home.html <span style='color:#111;'> 1.60KB </span>","children":null,"spread":false},{"title":"new-customer.html <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false},{"title":"create-greeting.html <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false},{"title":"new-order.html <span style='color:#111;'> 1.15KB </span>","children":null,"spread":false},{"title":"create-order.html <span style='color:#111;'> 1.74KB </span>","children":null,"spread":false},{"title":"orders.html <span style='color:#111;'> 1.50KB </span>","children":null,"spread":false},{"title":"create-customer.html <span style='color:#111;'> 1.62KB </span>","children":null,"spread":false},{"title":"new-greeting.html <span style='color:#111;'> 987B </span>","children":null,"spread":false},{"title":"customer-orders.html <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false}],"spread":false},{"title":"static","children":[{"title":"test.js <span style='color:#111;'> 0B </span>","children":null,"spread":false},{"title":"vendor","children":[{"title":"js","children":[{"title":"jquery.slim.min.js <span style='color:#111;'> 68.28KB </span>","children":null,"spread":false},{"title":"popper.min.js <span style='color:#111;'> 20.48KB </span>","children":null,"spread":false},{"title":"bootstrap.min.js <span style='color:#111;'> 54.47KB </span>","children":null,"spread":false}],"spread":true},{"title":"css","children":[{"title":"bootstrap.min.css <span style='color:#111;'> 149.59KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true},{"title":"application.yml <span style='color:#111;'> 21B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"kafkastream","children":[{"title":"constants","children":[{"title":"KafkaConstants.java <span style='color:#111;'> 1.42KB </span>","children":null,"spread":false}],"spread":true},{"title":"service","children":[{"title":"CustomRestTemplateService.java <span style='color:#111;'> 2.28KB </span>","children":null,"spread":false}],"spread":true},{"title":"dto","children":[{"title":"GreetingDTO.java <span style='color:#111;'> 446B </span>","children":null,"spread":false},{"title":"CustomerDTO.java <span style='color:#111;'> 675B </span>","children":null,"spread":false},{"title":"CustomerOrderDTO.java <span style='color:#111;'> 1.87KB </span>","children":null,"spread":false},{"title":"OrderDTO.java <span style='color:#111;'> 745B </span>","children":null,"spread":false}],"spread":true},{"title":"model","children":[{"title":"Order.java <span style='color:#111;'> 19.78KB </span>","children":null,"spread":false},{"title":"CustomerOrder.java <span style='color:#111;'> 29.70KB </span>","children":null,"spread":false},{"title":"Customer.java <span style='color:#111;'> 19.06KB </span>","children":null,"spread":false},{"title":"Greetings.java <span style='color:#111;'> 11.95KB </span>","children":null,"spread":false}],"spread":false},{"title":"KafkaStreamApplication.java <span style='color:#111;'> 332B </span>","children":null,"spread":false},{"title":"web","children":[{"title":"EventsController.java <span style='color:#111;'> 3.96KB </span>","children":null,"spread":false},{"title":"kafkarest","children":[{"title":"StateStoreRestService.java <span style='color:#111;'> 10.40KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"util","children":[{"title":"HostStoreInfo.java <span style='color:#111;'> 1.95KB </span>","children":null,"spread":false},{"title":"MetadataService.java <span style='color:#111;'> 2.83KB </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"ApplicationConfig.java <span style='color:#111;'> 970B </span>","children":null,"spread":false}],"spread":false},{"title":"events","children":[{"title":"EventsSender.java <span style='color:#111;'> 3.98KB </span>","children":null,"spread":false}],"spread":false},{"title":"EventsListener.java <span style='color:#111;'> 9.57KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"CONTRIBUTING.md <span style='color:#111;'> 4.12KB </span>","children":null,"spread":false},{"title":"LICENSE <span style='color:#111;'> 34.33KB </span>","children":null,"spread":false},{"title":".mvn","children":[{"title":"wrapper","children":[{"title":"maven-wrapper.jar <span style='color:#111;'> 46.49KB </span>","children":null,"spread":false},{"title":"maven-wrapper.properties <span style='color:#111;'> 110B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 3.26KB </span>","children":null,"spread":false},{"title":"Jenkinsfile <span style='color:#111;'> 181B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 7.86KB </span>","children":null,"spread":false},{"title":"CODE_OF_CONDUCT.md <span style='color:#111;'> 3.25KB </span>","children":null,"spread":false},{"title":".gitignore <span style='color:#111;'> 290B </span>","children":null,"spread":false}],"spread":false}],"spread":true}]
评论信息
其他资源
- F1_ADC+DMA采集正弦波.zip
- 北京行政区shp
- BP神经网络、ELM极限学习机、SVM支持向量机MATLAB代码，以及测试数据，用于回归预测
- APP商业计划书
- Fast Hankel Transform.zip
- 获取Android设备常见硬件信息
- stm32_gd32 gcc编译代码工程
- wpf实现可编辑listview（新版）
- EDA测试（银行叫号机设计）
- 摄影入门基础知识.ppt
- C语言实现的NTP， 可时间同步
- matlab烟雾检测
- zxing jar包
- Building The Data Warehouse 4th Edition
- 期末考试复习uml复习资料
- 2019年北京邮电大学801通信原理考研真题
- 大学生交友网概要设计设计文档
- 非均匀采样的频谱研究
- curl-7.74.0.tar.gz
- echarts数据分页
- 即构科技产品白皮书_实时语音视频云服务
- JSp简易留言板
- 墨西哥帽小波变换
- Nessus中策略参数详解(中文版)
- CS大作业-hello的“一生”
- UDP动态温度曲线图
- STM32 定时器捕获PWM波 以及占空比
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明