Apache-Kafka中的多租户支持

如何解决Apache-Kafka中的多租户支持

我有一个场景，其中多个客户端想要产生和使用消息。有没有一种方法可以在apache kafka中实现 multi-tenancy ，以便一个客户端由于另一客户端的大量流入而保持完整。 基本上，我想要一种将客户端标记为代理的方法，并且该客户端上的所有主题/分区都将属于标记的代理。 在这里，一个客户端在内部产生和使用消息。他们这样做是为了实现分布式处理。例如，将父邮件分解为子级，并在任何机器中生产/处理这些子级。

解决方法

客户端从其他客户端失败的原因之一是由于这些其他客户端导致代理的I / O饱和。

对此进行保护的方法是使用enforce quotas。

不确定我是否理解“标记”的含义，因为您无法控制群集中分区的放置，因此无法将数据从特定客户端发送到特定代理，除非您首先要创建一个主题然后手动重新分配参与和副本放置。