spring-boot - 分布式系统中不同类型的事件——拆分或合并

Question

当你有关于不同实体的事件时，他们应该讨论相同的主题还是不同的主题？在这里，我更喜欢使用 Kafka 作为发布者和消费者之间的消息传递系统。这些不同的来源具有不同的模型，只有很少的共同属性和其他特定于每个模型的属性。这些模型的原始数据/事件将单独处理。

Q1。让我们考虑两个不同的模型充当流的发布者或源。在分布式系统中，他们应该将事件推送到单个主题还是各个主题？

Q2。如果一个事件涉及多个实体怎么办？例如，不仅仅是上面提到的两种模型，还有数千种 Kafka 延迟会受到影响的模型，例如与购买相关的模型、产品和客户，以及从一个帐户到另一个帐户的转移至少涉及这两个帐户。

Q3。对于这两种情况，首选哪种模式 AVRO（不断发展，但每个主题只有一个模型）或 JSON 模式？

标签： spring-bootapache-kafkadistributed-system