nileshkumar3 opened a new pull request, #22338: URL: https://github.com/apache/kafka/pull/22338
Ref: https://issues.apache.org/jira/browse/KAFKA-8073 ## Causes 1. `produceUntilThrottled` sent tiny payloads, so on slow hosts the 1000 sends could stay under the 8000 B/s producer quota and never trigger a throttle. 2. The broker `throttle-time` metric was cached once before the send loop, so the lazily-registered sensor could be missed. 3. `verifyThrottleTimeRequestChannelMetric` asserted on the broker `ThrottleTimeMs` histogram immediately, before the broker had recorded the value. ## Changes - Use a fixed 2 KB payload in `produceUntilThrottled` so the quota is reliably exceeded. - Re-read the broker throttle-time metric inside the send loop. - Poll the RequestChannel `ThrottleTimeMs` via `TestUtils.waitUntilTrue`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
