kafka作爲事件源系統中的事件存儲區

Question

此問題與Using Kafka as a (CQRS) Eventstore. Good idea?類似，但更具體實現。 如何使用kafka作爲事件存儲，當我有成千上萬的事件「來源」（DDD中的聚合根）？正如我在鏈接問題和其他地方閱讀過的，每個源代碼都會遇到問題。如果按類型將事件分割爲主題，則消耗和存儲起來會更容易，但我需要訪問特定源的事件流。如何使用kafka進行活動採購？

Answer 1

將所有事件源都發布到具有數據類型（thrift？）的單個主題，該數據類型包含每個事件源的一些唯一標識符。然後針對您感興趣的每種事件類型創建消費者，並用唯一的消費者組名稱標識每個事件類型。通過這種方式，每個獨特的源消費者將在zookeeper中擁有自己的偏移值。每個人都閱讀整個主題，但只輸出（或處理）來自單個來源（或來源組）的信息。