我正在为我们公司正在构建的一个新的事件和流处理系统设计一组模式，以便将几个当前断开连接的系统连接起来。我们已经清楚地定义了12个域模型，现在正在尝试将一组事件模式组合在一起，所有应用程序都将通过事件到OutConfluent（kafka）平台。然后，samza将提取并处理这些数据，以执行各种作业，然后为我们的特定领域服务填充数据库。
这一切都很好，我们从每个域（例如地址）一个事件开始，但是，我们很快遇到了需要不同类型事件的不同数据的问题。例如，创建地址的事件需要域中的所有（或大部分）字段。而更新只需要一个id和更新的内容。
所以，我要找的是过去做过这件事的人的一些建议？理想情况下，我希望每个域只使用一个事件模式来保持它的整洁。这样，每个事件都有一个对应的kafka队列，可以轻松地重放以恢复状态或返回到特定的前一个状态。但是，感觉更简单、更实用的方法是为每个动词使用一个单独的模式（即create、update、delete）
一些相关的堆栈细节：
融合rest代理->avro->kafka->samza->各种数据库。