guozhangwang opened a new pull request #8565:
URL: https://github.com/apache/kafka/pull/8565


   Comparing all other test cases, the `shouldAllowConcurrentAccesses` starts 
an async producer sending records throughout the test other than just 
synchronously sent and acked a few records before we start the streams 
application. Right after the streams app is started, we check that at least one 
record is sent to the output topic (i.e. completed processing). However since 
only this test starts the producer async and did not wait for it to complete, 
it is possible that the async producer gets too longer to produce some records 
and causing it to fail.
   
   To follow what other tests did, I let this test to first send one round of 
records synchronously before starting the async producing.
   
   Also encountered some new scala warnings that I fixed along with this PR.
   
   ### 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.

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


Reply via email to