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

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

  •  0
  • Raman  · 技术社区  · 6 年前

    一个拓扑中的两个并行处理器能否在同一个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 回复  |  直到 6 年前
        1
  •  1
  •   Matthias J. Sax    6 年前