| commit | c11368628a6928cdd92a1fcd436284fe37d4f7b4 | [log] [tgz] |
|---|---|---|
| author | Luca Milanesio <luca.milanesio@gmail.com> | Tue Feb 26 11:02:51 2019 +0000 |
| committer | Luca Milanesio <luca.milanesio@gmail.com> | Tue Feb 26 11:02:51 2019 +0000 |
| tree | 1107064fe393de9adc07c4432ff90dd5c93e85b7 | |
| parent | 56f6f8d081f9388e7569d786140b08630d1fe975 [diff] |
Increase Kafka receive patience to 30s When receiving messages from Kafka in our tests, they may come a bit later than we thought and we risk to make tests flaky. Limit raised to 30s for declaring that we have not received a message and thus the test must fail. Change-Id: If9b738e38143eb1bce242343c3e4e3b0efeecc64
diff --git a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java index 98953bf..993c138 100644 --- a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java +++ b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
@@ -44,7 +44,7 @@ sysModule = "com.googlesource.gerrit.plugins.multisite.kafka.consumer.EventConsumerIT$KafkaTestContainerModule") public class EventConsumerIT extends LightweightPluginDaemonTest { - private static final int QUEUE_POLL_TIMEOUT_MSECS = 2000; + private static final int QUEUE_POLL_TIMEOUT_MSECS = 30000; public static class KafkaTestContainerModule extends LifecycleModule {