microservices demo:2个通过Kafka消息代理相互通信的微服务的示例项目 源码

### Abstract这是一个示例演示项目,演示了两个微服务通过Apache Kafka消息代理以异步方式彼此通信。 这些项目包括两项服务: 用户服务 通知服务 这些服务是使用Sprint Boot和Java 11构建的。 用户服务 用户服务处理用户的批量操作: 登记 版 删除(软删除) 该服务使用内存中的H2数据库(为简单起见,因为这是一个演示项目) 通知服务 Notification-service收听Kafka主题。 当来自Kafka的消息到达时,该服务会向该消息中指定的用户发送电子邮件通知。 ###使用Docker Compose运行 在docker-compose / .env文件中设置MAIL_USERNAME和MAIL_PASSWORD变量,以便通知服务知道将从哪个帐户发送电子邮件通知。 通过在每个模块的根目录中运行以下命令,为Notification-serv