This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3397cc9 KAFKA-9516; Increase timeout in testNonBlockingProducer to
make it more reliable (#9181)
3397cc9 is described below
commit 3397cc95626dcfe045b50c5f6ae5ec054e36a80d
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)
