用例:
从Kafka消耗数据,然后写入由最大QPS绑定的DB。
预测的解决方案:
将消耗速率限制到一个小于DB的最大写入QPS的限制。
查询:
Guava提供了一个可以在此处实现的速率限制器,但是Kafka是否支持消费者速率限制本身而不是实现第三方选项。
有关Kafka速率限制功能的参考:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-13+-+Quotas
另外,在这种情况下如何应用配额率限制?
最佳答案
最好的解决方案是使用第三方库。
Google的Guava是最好的,也是最容易使用的。
有关示例代码,有关番石榴速率限制器的用法,请参考this