Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
将 Apache Flink 与 Lagom 结合使用时出现 java.io.NotSerializedException
我正在 Lagom 的微服务实现中编写 Flink CEP 程序 我的 FLINK CEP 程序在简单的 scala 应用程序中运行得非常好 但是当我在 Lagom 服务实现中使用此代码时 我收到以下异常 拉戈姆服务实施 override
scala
flinkstreaming
lagom
flinkcep
列族 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 uti
cassandra
polymorphicassociations
akkapersistence
lagom
在 Lagom 微服务中摄取流数据的最佳方法
我正在创建流分析应用程序 其中每个分析 功能都将作为微服务实现 以便该分析可以稍后在不同的项目中使用 我正在使用 Lagom 来创建微服务 我是 lagom 的新人 这就是为什么我遇到一些疑问 我不明白将数据流 来自多个传感器 发布到微服务
scala
ApacheKafka
kafkaproducerapi
lagom
如何获取所有持久化实体
我对 lagom 框架完全陌生 因此 我今天正在阅读文档并开始修改他们的 hello world 示例 但是 我无法找到一种方法来获取所有持久实体 即本示例中的所有持久问候语 这是默认示例获取某人的问候语的方式 Override publi
Java
lagom
akkapersistence