用例:
从Kafka消耗数据,然后写入由最大QPS绑定的DB。

预测的解决方案:
将消耗速率限制到一个小于DB的最大写入QPS的限制。

查询:
Guava提供了一个可以在此处实现的速率限制器,但是Kafka是否支持消费者速率限制本身而不是实现第三方选项。

有关Kafka速率限制功能的参考:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-13+-+Quotas

另外,在这种情况下如何应用配额率限制?

最佳答案

最好的解决方案是使用第三方库。
Google的Guava是最好的,也是最容易使用的。

有关示例代码,有关番石榴速率限制器的用法,请参考this

10-07 16:08
查看更多