提交 551d42d8 编写于 作者: R Rajan 提交者: GitHub

Fix #91 intermittent test failure PulsarClientToolTest.testInitialzation (#94)

上级 e7f08a83
......@@ -62,7 +62,7 @@ public class PulsarClientToolTest extends BrokerTestBase {
try {
pulsarClientToolConsumer = new PulsarClientTool(properties);
String[] args = { "consume", "-t", "Exclusive", "-s", "sub-name", "-n",
Integer.toString(numberOfMessages), "--hex", "-r", "10", topicName };
Integer.toString(numberOfMessages), "--hex", "-r", "30", topicName };
Assert.assertEquals(pulsarClientToolConsumer.run(args), 0);
future.complete(null);
} catch (Throwable t) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册