我使用apache作为kafka的samza框架,需要在两个任务之间共享相同的rockdbs键值存储。在没有存储键值并发的情况下我能做什么?
pw136qt21#
我部署了两个具有相同键值存储的任务,它正在工作。所以我们可以。
lf3rwulv2#
从samza 0.12.0开始,任务之间不支持共享存储。为每个任务示例化(隔离)每个存储。有关更多信息,请参阅此处的“本地州”部分:http://samza.apache.org/learn/documentation/0.12/container/state-management.html
2条答案
按热度按时间pw136qt21#
我部署了两个具有相同键值存储的任务,它正在工作。
所以我们可以。
lf3rwulv2#
从samza 0.12.0开始,任务之间不支持共享存储。为每个任务示例化(隔离)每个存储。
有关更多信息,请参阅此处的“本地州”部分:http://samza.apache.org/learn/documentation/0.12/container/state-management.html