我是否在两个不同的streamtask中同时使用相同的键值存储(rockdbs)?

wmomyfyw  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(295)

我使用apache作为kafka的samza框架,需要在两个任务之间共享相同的rockdbs键值存储。
在没有存储键值并发的情况下我能做什么?

pw136qt2

pw136qt21#

我部署了两个具有相同键值存储的任务,它正在工作。
所以我们可以。

lf3rwulv

lf3rwulv2#

从samza 0.12.0开始,任务之间不支持共享存储。为每个任务示例化(隔离)每个存储。
有关更多信息,请参阅此处的“本地州”部分:http://samza.apache.org/learn/documentation/0.12/container/state-management.html

相关问题