jiafu1115 opened a new pull request, #13320: URL: https://github.com/apache/kafka/pull/13320
Hi Team: Refer to https://issues.apache.org/jira/browse/KAFKA-14768 There are two issues for current's producer: (1) Take much time to send the first record; (2) can't reduce the send message's block time (max.block.ms) to wanted lower value caused by worry about the only one time's metadata fetch in doSend's process. Test Result: At the beginning of the change, we will take 4s+ to send one message and must make sure max.block.ms > 4s. After the change: (1) reduce time for first record's sending: my example: warmup test_topic at phase phase 2: get metadata from mq start warmup test_topic at phase phase 2: get metadata from mq end consume 4669ms (2) can reduce max.block.ms to < 4s now. ### 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
