经纪人检测到配额违反(卡夫卡配额延迟)时如何反应?

问题描述 投票:0回答:1

在具有已定义配额的Kafka群集中,为了控制客户端使用的代理资源,代理会计算使违规客户端达到其配额以下所需的延迟量,并立即返回延迟Source from Kafka apache documentation

在本主题中,我想知道延迟指的是什么(请提供具体示例)?

据我所知,例如,当我们定义producer_byte_rate=1024时,经纪人监视生产者以不超过1024o /秒,如果生产者超过1024o /秒,则经纪人将通过限制客户的数量来降低客户端的配额。为该客户端保留的管道。

apache-kafka confluent
1个回答
1
投票

击中客户的行为达到了最近更改的配额

自Kafka 2.0起:当代理检测到客户端违反配额时,代理将计算使客户端重新回到其允许配额内所需的延迟并立即答复(包括响应中计算出的延迟)。然后,代理将客户端套接字静音,以使其在延迟时间内不再处理来自此客户端的任何其他请求。

在收到带有限制时间的响应后,“好”客户端应等待延迟,然后再尝试发送更多请求。代理会忽略在此期间发送的任何请求。

[2.0.0之前:违反时,代理没有等待立即答复,而是在等待限制时间,并且仅在此之后才向客户端发送响应。

© www.soinside.com 2019 - 2024. All rights reserved.