代码之家 › 专栏 › 技术社区 › Raman

卡夫卡溪:环球旅行社是安全的吗?

apache-kafka-streams apache-kafka

0

Raman · 技术社区 · 7 年前

一个拓扑中的两个并行处理器能否在同一个GlobalStore上执行Put/Get操作?例如,在下面的示例拓扑中,一个处理器使用(keyValueIterator)遍历存储区,而另一个处理器进行Put/Delete?

拓扑结构:

Source: source (topic: [input topic with 6 partitions])
    --> processor1
    --> processor2

Processor: processor1
    <-- source

Processor: processor2
    <-- source      

Global Stores:
  GlobalStore: globalstoresource (topic: [input topic with 1 partition])
      --> loadglobalstore (store: myglobalstore)

1 回复 | 直到 7 年前

1

Matthias J. Sax 7 年前