Adjust timeout in low resource environments
Author: Eno Thereska
Reviewers: Matthias J. Sax, Guozhang Wang
Closes from enothereska/KAFKA-4222-queryOnRebalance
@@ -287,7 +287,7 @@ public class QueryableStateIntegrationTest {
}
}
- }, 30000, "waiting for metadata, store and value to be non null");
+ }, 120000, "waiting for metadata, store and value to be non null");
}
}
@@ -319,7 +319,7 @@ public class QueryableStateIntegrationTest {
}
}
- }, 30000, "waiting for metadata, store and value to be non null");
+ }, 120000, "waiting for metadata, store and value to be non null");
}
}
@@ -850,7 +850,7 @@ public class QueryableStateIntegrationTest {
config,
topic,
numRecs,
- 60 * 1000);
+ 120 * 1000);
}
private Set<KeyValue<String, Long>> fetch(final ReadOnlyWindowStore<String, Long> store,
@@ -909,7 +909,7 @@ public class QueryableStateIntegrationTest {
final Properties producerConfig = new Properties();
producerConfig.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());
producerConfig.put(ProducerConfig.ACKS_CONFIG, "all");
- producerConfig.put(ProducerConfig.RETRIES_CONFIG, 0);
+ producerConfig.put(ProducerConfig.RETRIES_CONFIG, 10);
producerConfig.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
