确保发布服务器/订阅服务器模式的公平性

Question

当一个发布者生成数千条消息，而所有其他发布者的消息都在低位时，我如何确保Pub/Sub模式(例如kafka(中的公平性？目前还无法预测哪家生产商会有高活跃度。

如果其他制作人的其他消息不必因为一个制作人非常活跃而等待数小时，那就太好了。

这是什么模式？Kafka或其他类似Google PubSub的技术有可能吗？如果是，如何？

在这种情况下，多个分区也不能很好地工作，或者我可以理解。

Answer 1

在Kafka中，您可以利用配额的概念来防止某些客户端垄断集群资源。

有两种类型的配额可以强制执行：

1. 网络带宽配额
2. 请求速率配额

有关如何配置这些功能的更多详细信息，请参阅Kafka的官方文档。