[kafka] 01/02: KAFKA-9516; Increase timeout in testNonBlockingProducer to make it more reliable (#9181)

[rs...@apache.org]

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 <ra...@googlemail.com>
AuthorDate: Sun Aug 16 10:30:03 2020 +0100

    KAFKA-9516; Increase timeout in testNonBlockingProducer to make it more reliable (#9181)
    
    Reviewers: Ismael Juma <is...@juma.me.uk>
---
 .../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)