我有一个场景,多个客户机想要生成和使用消息。在apachekafka中有没有一种方法可以实现多租户,这样一个客户机就可以被另一个客户机的大量流入保持完整。基本上,我想要一种将客户机标记为代理的方法,并且该客户机上的所有主题/分区都将属于标记的代理。在这里,一个客户机在内部生成和使用消息。他们这样做是为了实现分布式处理。例如父消息被分解成子消息,并在任何机器中生成/处理这些子消息。
hjzp0vay1#
客户机从其他客户机失败的一个原因是由于其他客户机导致的代理上的i/o饱和。防止这种情况发生的方法是实施配额制。我不太明白您所说的“标记”是什么意思,因为您无法控制集群中的分区放置,所以从特定客户端向某些代理发送数据是不可能的,除非您先创建一个主题,然后手动重新分配分区和副本放置。
1条答案
按热度按时间hjzp0vay1#
客户机从其他客户机失败的一个原因是由于其他客户机导致的代理上的i/o饱和。
防止这种情况发生的方法是实施配额制。
我不太明白您所说的“标记”是什么意思,因为您无法控制集群中的分区放置,所以从特定客户端向某些代理发送数据是不可能的,除非您先创建一个主题,然后手动重新分配分区和副本放置。