Kafka消费者：最大消费者率

我对学习/推导我的消费者组中一个 Kafka 消费者的最大消费率感兴趣。 最大消费率是消费者跟不上消息到达率的速率，因此消费者会越来越落后，消息滞后就会累积。

在消费者端，我可以计算最大消费率1/(消息等待时间)，其中消息等待时间 strong> 是从代理中提取消息并由消费者在轮询循环中对其进行处理所需的时间。

该策略是否会返回对消费者最大消费率的准确度量。关于使用消费者 API 计算最大消费率的任何其他建议？

另一方面，假设我有一个带有 Kafka 管理客户端 API 的控制器进程，下面的逻辑是否会准确返回最大消耗率（任何看不见的边界情况）。在逻辑上，At和Rt是t时刻的到达和消费者率，t-1时刻为At-1和Rt-1

if (At > At-1 && Rt = Rt-1) then Rt is the maximum consumption rate.

对于使用管理客户端 API 而不是消费者 API 计算最大消耗率有什么建议吗？

谢谢。