showuon commented on pull request #11691: URL: https://github.com/apache/kafka/pull/11691#issuecomment-1023998660
@mimaison , I've updated the PR and fix the flaky tests. The tests will fail because we have 2 threads: Producer thread and Sender thread in producer. And before the latest commit, I have a bad assumption that the sender thread will run after producer send, so the called times verification will be passed. (ex: `verify(metadata, times(5)).fetch();`) I fixed it by removing the the need to fetch metadata in sender thread, so that we can focus on testing the producer behavior as we expected. Thanks. -- 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
