@lindong28 Thanks! I added a timeout for the `producer.send()`. I think that we need the `producer.send()` to be retried inside the `waitUntilTrue` because we need to wait on a `KafkaStorageException` to force a metadata update for the producer.
[ Full content available at: https://github.com/apache/kafka/pull/5695 ] This message was relayed via gitbox.apache.org for devnull@infra.apache.org
