kafka中每个实体的主题答案

【问题标题】：Topics per entity in kafkakafka中每个实体的主题
【发布时间】：2021-05-23 09:43:13
【问题描述】：

尝试设计一种可以接受订单请求并启动这些订单的运输流程的服务。尝试以事件驱动的方式完成这些工作。因此，订单的服务将发出一个传输请求事件，但我无法弄清楚传输请求的取消将如何推出，因为在取消之前可能已经有很多传输请求。另外，我读到为每个实体创建主题不是一个好主意。

【问题讨论】：

【解决方案1】：

在这种情况下，所有与订单相关的活动都是按顺序发生的，但取消可能随时发生。所以如果你需要应用这个，你需要使用 separate topic 取消same partitioning

注意：相同的分区在这里很重要，因为它将决定消费实例，具有相同键的相同实体应该转到相同的应用程序实例。所以分区数应该等于主主题分区数。

【讨论】：

是否有任何方法可以使用 Kafka 流或 Kafka 分支生成按订单服务？因为使用这种方法，我们可能必须为其他更新设置不同的主题，例如更改订单的传输优先级等，而且对于调试来说，这也会有点困难。这个页面谈论它，但没有明确提到解决方案。我喜欢你的方法，只是我认为如果有一些关于 kafka 主题的内容可以为我提供有关来自 key_id 的传输请求的完整信息，那会简单得多。