我正在努力学习/了解scala lagom kafka . 在网上搜索时发现了一个样本的Twitter项目,很好地解释了它(https://github.com/knoldus/lagom-scala.g8/tree/master/src/main/g8) . 在这个项目中,创建了两个Lagom微服务(消费者和 生产环境 者),他们通过kafka主题进行交流 . 但是,两个服务都在同一台服务器/机器上运行 .
我想知道是否有可能使用kafka主题在两个不同的服务器/机器上运行的两个lagom kafka微服务之间进行通信 . 通过修改kafka配置文件(zookeeper.properties和server.properties),我能够通过简单的kafka(没有Lagom)实现这种配置 .
Questions:
-
使用Lagom Kafka可以实现此配置(两个不同服务器上的 生产环境 者和使用者) .
-
如何在lagom框架中添加kafka配置(zookeeper.properties和server.properties) .
-
是否有任何项目使用上述配置 . 所以,我可以使用它作为参考,轻松理解Lagom Kafka .
1 回答
当然,是的 .
有关于此的文档:
https://www.lagomframework.com/documentation/1.4.x/java/KafkaClient.html
https://www.lagomframework.com/documentation/1.4.x/java/KafkaServer.html
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
儒勒