This is an automated email from the ASF dual-hosted git repository. rsivaram pushed a commit to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 6bb81ae094d89b4d1d5d6daa4d350a0deb873204 Author: Rajini Sivaram <[email protected]> AuthorDate: Sun Aug 16 10:30:03 2020 +0100 KAFKA-9516; Increase timeout in testNonBlockingProducer to make it more reliable (#9181) Reviewers: Ismael Juma <[email protected]> --- .../test/scala/integration/kafka/api/PlaintextProducerSendTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala b/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala index 7f707a1..c49523e 100644 --- a/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala +++ b/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala @@ -145,7 +145,7 @@ class PlaintextProducerSendTest extends BaseProducerSendTest { } def verifySendSuccess(future: Future[RecordMetadata]): Unit = { - val recordMetadata = future.get(10, TimeUnit.SECONDS) + val recordMetadata = future.get(30, TimeUnit.SECONDS) assertEquals(topic, recordMetadata.topic) assertEquals(0, recordMetadata.partition) assertTrue(s"Invalid offset $recordMetadata", recordMetadata.offset >= 0)
