akka-persistence

1热度

1回答

在写日记的不同选项来实现事件采购，卡夫卡似乎从“外部”一个非常合理的选择：它有一个很大的生态系统它是有据可查的它自然地支持流媒体和听众然而，寻找到阿卡持久性，似乎只有通过社会贡献packag卡夫卡日记支持e，这在过去的2年里没有被修改过。卡夫卡不是一个好的选择，是否有更好的选择，如果这是最好的选择，那么人们是如何使用它的akka-persistance？

1热度

1回答

如何在崩溃后重新创建动态创建的持久性AKKA演员

我正在评估Akka的项目，并试图通过将演员状态保存在高可用数据中来确定是否可以通过Akka-Persistence实现服务的高可用性商店。（我不是indending使用Akka集群）我理解保存演员国家的概念，但我很努力找到一种方法来重新创建演员（不是演员国家）恢复我的失败（坠毁）服务在备份主机上。在我的设计中，有很多动态创建的角色，只有少数是在服务启动时创建的。如何找出在恢复时需要创建的演

1热度

1回答

deliveryId owerflow从阿卡持久

我试图实施为不同的演员可靠的消息传递一些AtLeastOnceDelivery装饰AtLeastOnceDelivery担保。所以这样的装饰器试图处理非常密集的消息，并将与应用程序共享lyfecycle。根据AtLeastOnceDelivery documentation的deliveryId是无间隙（长）严格单调递增的序列号。的问题是：当值溢出最大久了会发生什么？ akka-persist

0热度

1回答

使用间接参考查找以前持续存在的Akka演员

我目前正在建立一个系统中有相当多的地方，其中有多种方法可以联系到同一个演员。例如，如果你有一个持久的汽车演员，你可以使用VIN或车牌。由于我们在重新创建actor时需要一个“真实名称”作为actor名称/持久性ID，因此这些“lookups/references”本身就是actors，它们以键名命名，只保留actor的ID参考。这似乎是正确的方法吗？好像很多演员不是真正的演员，只是代理人。

2热度

1回答

列家族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.ConfigurationEx

0热度

1回答

更改为持续查询从弃用PersistentView

我用阿卡持久性，与性LevelDB作为存储插件，在用Scala编写的应用程序。在查询方面，目前执行的只知道演员的标识符采用PersistentView，其调查的消息从PersistentActor的日记。现在我已经了解到，PersistentView已被弃用，一个是鼓励使用持久查询代替。但是，我还没有找到关于如何修改使用PersistentView来支持首选持久性查询实现的详细说明。任何帮助，

0热度

1回答

如何将akka sharded actor状态外部化为redis或ignite？

我对Akka聚类和研究概念证明非常陌生。在我的情况下，我有一个在群集上运行的演员，演员的状态为Map [String，Any]。因此，对于任何请求，actor根据传入的消息接收它，它会创建一个新的实体actor和数据映射。这里的问题是地图现在在内存中。是否有可能在Redis或点燃某个地方存储Sharded actor状态？

0热度

1回答

问题ReceiverActor和ReceivePersistentActor测试拌上Akka.Persistence.TestKit

网络用户，现在我'开发一种使用行为者ReceiveActor继承和演员从ReceivePersistentActor继承的应用程序。我使用Akke.Net，Akke.Persistence，Akke.TestKit版本1.3.1和Akka.Persistence.TestKit版本1.2.3.43-beta。现在我用NUnit编写了一个ReceiveActor的测试类，并且Akke.Test

0热度

1回答

访问/授权控制：akka-persistence /服务层/ akka-http堆栈

有一个web应用程序在服务器上使用以下堆栈： akka-persistence/service-layer/akka-http（for REST）问题是：我怎样才能 - 以最优雅，最干燥的方式 - 确保只有那些用户可以执行服务层中有权这样做的功能（在给定的输入参数下）。因此，例如，让我们简单的例子： getEntity(userID:UserID, ref:EntityID):Entity

3热度

1回答

Akka持久性：删除日记中的“旧”消息

清理快照存储区中的旧快照非常简单：每次成功快照后，参与者都会收到一个saveSnapshotSuccess，元数据指示其序列号，该信息可用于构造快照SnapshotSelectionCriteria，然后送到deleteSnapshots。然而，对于持久性消息，没有等同于saveSnapshotSuccess。因此，不可能知道期刊中“最后一条”消息的序列号。可以保留持续消息的本地缓存计数并将其快