Lagom 使用 Kafka 发布消息
此处仅描述了一种发布方式.还有别的方法吗?我需要使用动态主题 ID 和自定义事件制作发布而不使用 persistentEntityRegistry 的示例?以及如何使用 eventId 发布事件? @Override默认描述符描述符(){返回named("helloservice").withCalls(pathCall("/api/hello/:id", this::hello),pathC
..
lagom相关内容
在 Lagom 微服务中摄取流数据的最佳方法
我正在创建流分析应用程序，其中每个分析/功能都将作为微服务实现，以便以后可以在不同的项目中使用这种分析. 我正在使用 Lagom 来创建微服务.我是拉戈姆的新手，这就是为什么我遇到了一些疑问. 我不明白将我的数据流(来自多个传感器)发布到微服务，然后该微服务将数据发布到 kafka 主题的最佳方法是什么. 服务描述中是否有流消息的Lagom特性服务调用[源[字符串，未使用]，源[
..
Lagom用Kafka发布消息
此处仅描述了一种发布方式. 还有另一种方法吗? 我需要使用动态主题ID和自定义事件创建发布而没有persistentEntityRegistry的示例吗? 以及如何使用eventId发布事件? @Override default Descriptor descriptor() { return named("helloservice").withCalls( p
..
如何获取所有持久化实体
我对lagom框架完全陌生，因此，我今天正在阅读文档，并开始修改其hello world示例. 但是，我无法找到一种方法来获取所有持久化的实体(即此示例中的所有持久化问候). 这是默认示例获取某人问候的方式: @Override public ServiceCall useGreeting(String id) { return
..
Lagom框架/流式响应/websocket/pathCall/Descriptor/Creator代替Function
我以这种方式声明了我的服务: public interface BlogQueryService extends Service { public ServiceCall> tick(int interval); public ServiceCall> tock(); pub
..
为Lagom Java启用CORS过滤器
我已经按照跨域资源共享的说明进行操作，从localhost:3000(我的有角度的前端正在运行)访问localhost:9000(运行我的微服务的Lagom GateWay).但我仍然面对: XMLHttpRequest cannot load http://localhost:9000/api/myservice. No 'Access-Control-Allow-Origin' head
..
Lagom:命令处理程序中的异步操作
在Lagom中，当命令处理程序必须执行一些异步操作时您会怎么做?例如: override def behavior = Actions().onCommand[MyCommand, Done] { case (cmd, ctx, state) => // some complex code that performs asynchronous operations //
..
列族ID不匹配（发现52ac10b0-6e1b-11e7-82d3-c39cc53c1347;预期为42e51050-6e1b-11e7-82d3-c39cc53c1347）
我正在运行Lagom online-auction-java并出现错误，当我执行sbt clean runAll时在下面运行时 错误[Native-Transport-Requests-13] 2017-07-21 16：52：45,704 ErrorMessage.java:384-请求 期间发生意外异常java.lang.RuntimeException：java.util.concur
..
Lagom消息在持久性参与者和读取处理器之间的持久性
只是想知道从lagom中持久事件源参与者到事件处理器的事件通知传递的保证，对于通知到读取处理器的事件通知是否存在消息持久性或持久性？ 我知道最终的一致性很好，但是我正在谈论向Cassandra读取处理器发出事件处理程序通知。 解决方案 通过在持久实体中使用事件源和在读取侧处理中使用偏移量跟踪，可以保证事件处理。 当您的持久实体命令处理程序持久化事件时，每个事件都以有序”偏移“
..
Akka中第二类型参数的用途和含义是什么
akka.Source 中第二类型参数的用途和含义是什么？ 示例代码：- def流：ServiceCall [Source [String，NotUsed]，Source [String，NotUsed]] 根据我到目前为止所看到的代码，默认第二类型参数设置为 akka.NotUsed 。但是我不知道它的意义是什么。 解决方案 第二个参数是物化值，即当您运行
..
列族ID不匹配(找到cebcc380-72d4-11e7-9a6b-bd620b945799；预期为c05d6970-72d4-11e7-9a6b-bd620b945799)
如何解决此错误 列族ID不匹配(发现cebcc380-72d4-11e7-9a6b-bd620b945799；预期为c05d6970-72d4-11e7-9a6b-bd620b945799) Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exceptions.Configuratio
..
简单的微服务框架
一段时间以来，我一直在寻找一种快速，简单的微服务框架解决方案.我对所有Lightbend产品& scala，但由于它看起来非常有趣，因此我决定尝试一下. 几个问题: 1)我不明白为什么需要新的框架Lagom? 如果play已经可以给我相同的解决方案(用作微服务)，那么为什么需要另一个框架? 2)通过玩游戏，我设法快速创建了一个"Hello World"项目，并且部署也非常简
..
配置Kubernetes Nginx进行外部访问
我还是Kubernetes和Lagom的新手. 我需要从外部服务器调用我的Lagom微服务.为此，我认为我需要公开我的Nginx入口以进行外部访问，但是我不知道该怎么做.我应该配置“外部IP"吗? { "apiVersion": "v1", "kind": "Service", "metadata": { "name": "nginx-ingress" },
..
在Lagom Microservice中提取流数据的最佳方法
我正在创建流分析应用程序，其中的每个分析/功能都将实现为微服务，以便该分析以后可以在其他项目中使用. 我正在使用Lagom创建微服务.我是Lagom的新手，这就是为什么我遇到一些疑问的原因. 我不知道将数据流(来自多个传感器)发送到微服务，然后该微服务将数据发布到kafka主题的最佳方法是什么. 服务描述中的流消息是否具有Lagom功能 ServiceCall [Source [
..