CQRSBilling:课程“ Scala开发人员” Otus的项目工作 源码

CQRS帐单 来自Otus的课程设计工作。 将CQRS模板用于名义电信公司的计费系统 问题的提法 Kafka接收有关电话,短信和消耗的互联网流量的数据: 通话-有关通话信息的主题 文字-有关短信的主题 网络-有关互联网流量数据的主题 必须检查,保存数据并提供对它们的访问权限。 执行 Kafka,Cassandra和PostgreSQL在Docker中运行。 Writer从Kafka中获取流,对其进行过滤,然后将其作为消息流放入Cassandra中。 阅读器从Cassandra读取消息流,并更新PostgreSQL DBMS中的数据。 查询提供了用于访问数据的REST接口: Akka HTTP 貘 光滑的 Generator会在Kafka中创建一个数据流以进行测试: ZIO配置 ZIO卡夫卡 ZIO记录 绕圈