如何在支持qps的基础上限制kafka消费者？

jslywgbw 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(562)

用例：使用来自kafka的数据，然后写入到由max qps绑定的db。
预测解决方案：将消耗速率限制到小于db的最大写入qps的极限。
质疑：guava给出了一个可以在这里实现的限速器，但是kafka是否支持消费者限速本身而不是实现第三方选项。
Kafka速率限制特性参考：https://cwiki.apache.org/confluence/display/kafka/kip-13+-+quotas
另外，在这种情况下，如何适用配额率限制？

Java apache-kafka kafka-consumer-api

来源：https://stackoverflow.com/questions/53369992/how-to-throttle-kafka-consumer-on-the-basis-of-qps-to-be-supported