我是否同时在 2 个不同的 StreamTask 中使用相同的键值存储(RockDB)?

Do I use the same key-value storage (RockDBs) in 2 different StreamTask same time?

我使用 Apache 作为 Kafka 的 Samza 框架,我需要在 2 个任务之间共享相同的 RockDBs 键值存储。

我可以在没有存储键值并发的情况下这样做吗?

我部署了 2 个具有相同键值存储的任务并且它正在运行。

是的,我们可以。

从 Samza 0.12.0 开始,不支持在任务之间共享存储的方式。每个商店都为每个任务实例化(隔离)。

有关详细信息,请参阅此处的 "Local State" 部分: http://samza.apache.org/learn/documentation/0.12/container/state-management.html