dengziming opened a new pull request, #12238:
URL: https://github.com/apache/kafka/pull/12238

   *More detailed description of your change*
   Will will generate NoOpRecord periodically to increase metadata LEO, 
however, when a broker startup, we will wait until its metadata LEO catches up 
with the controller LEO, we generate NoOpRecord every 500ms and send heartbeat 
request every 2000ms. 
   
   It's almost impossible for a broker to catch up with the controller LEO if 
the broker sends a query request every 2000ms but the controller LEO increases 
every 500ms, so the tests in `KRaftClusterTest` will fail.
   
   
![image](https://user-images.githubusercontent.com/26023240/171584207-82a33962-a2f0-4af9-a0bb-09a42bb030e1.png)
   
   
   *Summary of testing strategy (including rationale)*
   After this change, the tests in `KRaftClusterTest` all succeed.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   


-- 
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: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to