Skip to content
代码片段 群组 项目
提交 6bb81ae0 编辑于 作者: Rajini Sivaram's avatar Rajini Sivaram
浏览文件

KAFKA-9516; Increase timeout in testNonBlockingProducer to make it more reliable (#9181)

Reviewers: Ismael Juma <ismael@juma.me.uk>
上级 1560effc
No related branches found
No related tags found
无相关合并请求
......@@ -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)
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册