我试图详细地学习/理解scala+lagom+kafka。在网上搜索时，发现了一个示例twitter项目，它很好地解释了这一点(https://github.com/knoldus/lagom-scala.g8/tree/master/src/main/g8). 在这个项目中，创建了两个lagom微服务（消费者和生产者），它们通过kafka主题进行交流。但是，这两个服务运行在同一台服务器/机器上。
我想知道是否有可能有两个lagom+kafka微服务之间的通信运行在两个不同的服务器/机器使用kafka主题。我能够通过简单的kafka（没有lagom）实现这个配置，通过修改kafka配置文件（zookeeper.properties和server.properties）。
问题：
这种配置（两个不同服务器上的生产者和消费者）是否可以使用lagom+kafka。
如何在lagom框架中添加kafka配置（zookeeper.properties和server.properties）。
是否有任何项目利用上述配置。所以，我可以以此为参照，轻松理解拉格姆+Kafka的作品。
1条答案
按热度按时间r8uurelv1#
这种配置（两个不同服务器上的生产者和消费者）是否可以使用lagom+kafka。
当然，是的。
2.如何在lagom框架中添加kafka配置（zookeeper.properties和server.properties）。
有相关文件：
https://www.lagomframework.com/documentation/1.4.x/java/kafkaclient.html
https://www.lagomframework.com/documentation/1.4.x/java/kafkaserver.html
是否有任何项目利用上述配置。所以，我可以以此为参照，轻松理解拉格姆+Kafka的作品。
lagom github中有一些示例项目：
https://github.com/lagom/online-auction-scala
https://github.com/lagom/online-auction-java
从哲学上讲，正是因为lagom服务托管在不同的服务器上（因此被网络分隔开），所以我们需要kafka，不管kafka托管在哪里。
我已经在这里解释了这个需要：https://discuss.lightbend.com/t/need-some-insight-on-lagoms-architecture/1369
朱尔斯