在非Lagom应用程序中嵌入Lagom读取端处理器

Question

我有一个Lagom服务，它将持久化实体的事件写入cassandra。我想通过嵌入一个连接到同一个cassandra的读取端处理器来处理来自另一个应用程序(不是基于lagom)的这些事件。

我没有找到任何关于如何将lagom服务或读取端处理器嵌入到现有java/scala应用程序中的文档，这是可能的吗？

Answer 1

不建议多个服务共享同一个数据库。这会导致服务之间的紧密耦合，并可能使其难以在未来升级。

相反，您可以使用Lagom Message Broker Topic Producer API将事件发布到Kafka主题。然后，您可以从另一个应用程序使用这些内容，可以使用带有Message Broker Consumer API的Lagom，也可以使用任何其他Kafka客户端。