基于带有DDD和CQRS的事件驱动架构的解决方案。 该解决方案包含以下应用程序。 生产者Web API,它接收产生域事件的命令。 这也接收查询并返回JSON。 消费者控制台应用程序,它读取事件流并投影到MongoDB数据库。 用于身份验证和JWT生成的Web API。 要求 环境设定 如果您已经具有适用于Kafka和MongoDB的有效连接,则可以跳过此步骤,然后转到“运行应用程序”步骤。 运行./up-kafka-mongodb.sh bash脚本以将Kafka和MongoDB作为Docker容器运行。 请等到〜800mb下载完成。 $ ./up-kafka-mongodb.sh