You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/05/09 16:23:40 UTC
kafka git commit: KAFKA-4222: Adjust timeout in low resource
environments
Repository: kafka
Updated Branches:
refs/heads/trunk 78ace3725 -> 5b36adde4
KAFKA-4222: Adjust timeout in low resource environments
Author: Eno Thereska <en...@gmail.com>
Reviewers: Matthias J. Sax, Guozhang Wang
Closes #2996 from enothereska/KAFKA-4222-queryOnRebalance
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5b36adde
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5b36adde
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5b36adde
Branch: refs/heads/trunk
Commit: 5b36adde4f158d9d3b47bb98123a0bcca8028288
Parents: 78ace37
Author: Eno Thereska <en...@gmail.com>
Authored: Tue May 9 09:23:35 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue May 9 09:23:35 2017 -0700
----------------------------------------------------------------------
.../streams/integration/QueryableStateIntegrationTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/5b36adde/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
index b435ceb..ab23af0 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
@@ -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);