This is an automated email from the ASF dual-hosted git repository. rsivaram pushed a commit to branch 2.6 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit f17a4122820954d63464f7fbdb140af1b10cea45 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 961b0f3..4e44f34 100644 --- a/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala +++ b/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala @@ -144,7 +144,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)
