设计 Apache-Kafka 场景

Question

我有以下场景： 我正在使用 Apache-Kafka 开发我的纳税和管理税收应用程序。 我有一个主要用例，我认为它需要通过 Apache Kafka 实现。 主要参与者是：我的应用程序，一些机构。

案例一： 我的应用程序是生产者。我的 Broker 中有一个名为 Users 的主题。当新客户决定在我的应用程序中创建帐户时，我的应用程序将在此主题中写入新的“消息”。我的应用程序正在与一些机构合作，因此我的应用程序会通知他们每个人有关新用户的信息。因此，我将机构视为消费者。我的应用程序需要将我所有用户的信息告知机构，这样之后，每个机构都会通知我我的每个用户是否需要向他们缴纳税款以及缴纳哪些税款。

我考虑了两种设计这个案例的方法：

1. 每个机构将是一个不同的消费者群体，其中将有一个消费者。
2. 每个机构将是不同的消费者，但都属于同一个消费者群体。 我明白第一种方式我的topic需要多分区，第二种方式可能会出现高并发的问题

Obs：随着新机构决定加入我的应用程序并与我的应用程序协作，他们将作为新消费者添加到 Kafka 系统中。

这是第一种方式

这是第二种方式