2017-04-20 29 views
0

我想使用samza,但是案例是我們的kafka話題的創造是有限的(話題創作應該被審查,並且應該具體具體)。 那麼,有沒有其他的選擇「job.coordinator.system」?我需要使用介紹。 非常感謝!有沒有job.coordinator.system的替代選擇

回答

0

作爲Samza 0.12.0的,Samza自動創建3類流:

  1. 協調員流持久地存儲作業模型的信息,例如主機親和性映射。
  2. 邊檢站流存儲檢查點輸入的消費流
  3. 更新日誌流與更新日誌任何商店啓用

這是很常見的使用卡夫卡登錄壓實主題對於這些,但理論上任何系統實現都可以工作。你甚至可以定義你自己的。

上Samza的流抽象的一些細節可以在這裏找到: http://samza.apache.org/learn/documentation/0.12/container/streams.html

+0

非常感謝你!也許我會先嚐試其他實時解決方案。 – beijicy