bbejeck opened a new pull request, #23718: URL: https://github.com/apache/kafka/pull/23718
`test_multi_topic_dlq_reject` and `test_multi_topic_dlq_release` start producer_a and producer_b back to back, then call await_produced_messages on each in turn. await_produced_messages records producer.num_acked when it is called and waits for that value plus min_messages. Both producers have max_messages=total_messages and run concurrently. If producer_b has acked any records by the time the wait on producer_a returns, the wait on producer_b asks for more than total_messages acks. That can never happen, so the test times out with "Timeout awaiting messages to be produced and acked". -- 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]
