java - 如何在卡夫卡和 Storm 背景下实现 Multi-Tenancy ？

在Kafka和Storm的背景下构建 Multi-Tenancy 应用的最佳实践是什么？

例如:为每个租户创建主题并使用多主题喷口(使用通配符)。

最佳答案

我认为每个租户的主题都是正确的选择。

命名约定可能是这样的:topic_base_name_tenant_id。

原因如下:

它允许为每个租户进行灵活的配置(例如前面提到的@Sebastian)。

更清晰的逻辑分隔。

现在，我们将使用不同的方法。例如，为每个租户分配分区。这可能是有问题的，因为:

您将并行度级别限制为租户数。

添加新的租户，结果添加新的分区→重新发布旧消息(默认分区算法为:message_key％partition_size)。

关于java - 如何在卡夫卡和 Storm 背景下实现 Multi-Tenancy ？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/23516427/