如何在Kafka中进行话题分类？

Question

例如，用户可以订阅特定类别的电影，当有新的电影出现在Kafka中时，我必须向订阅该类别电影的消费者发送相关信息。

当Kafka中出现一部新的电影时，我必须将该电影的信息发送给订阅该电影类别的消费者。

如何进行分类？使用partigion还是topic？因为分类可以超过1000个。

Answer 1

简单的创建一个主题 user-subscriptions 至少拥有 userID 和 categoryID. 对于每个订阅，确保创建一个不同的记录，即使是同一个用户。例如：

{"subscriptionID": 1, "userID": 1, "categoryID": 100}
{"subscriptionID": 2, "userID": 1, "categoryID": 26}
...

---

现在请确保按以下方式对这个主题进行分区 categoryID 以便将同一类别的记录放在同一个分区中。

现在，一旦您的应用程序识别出一个特定类别的新影片，您只需要查看存放该类别所有订阅的分区的记录，并在消费时使用 userID.