nileshkumar3 opened a new pull request, #22332: URL: https://github.com/apache/kafka/pull/22332
produceUntilThrottled currently caches the produce throttle metric reference before entering the polling loop. Since the broker registers the throttle metric lazily, the metric may not yet exist when the helper first reads it. In that case, the cached reference remains null for the lifetime of the method, preventing the helper from observing throttling even after the broker later records the metric. Reviewer - @muralibasani -- 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]
