You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/11/17 06:27:15 UTC
[2/2] incubator-kylin git commit: minor: change kafka client config:
retry.backoff.ms from default to 1000ms
minor: change kafka client config: retry.backoff.ms from default to 1000ms
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/6ae2bfc4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/6ae2bfc4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/6ae2bfc4
Branch: refs/heads/2.x-staging
Commit: 6ae2bfc4875621832f54a115f497eb0a350f05ab
Parents: 41ca5d2
Author: honma <ho...@ebay.com>
Authored: Tue Nov 17 13:29:27 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Nov 17 13:29:27 2015 +0800
----------------------------------------------------------------------
.../test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/6ae2bfc4/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
index c3caa9b..27e3897 100644
--- a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
+++ b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
@@ -36,6 +36,7 @@ public class KafkaDataLoader {
props.put("metadata.broker.list", brokerList);
props.put("serializer.class", "kafka.serializer.StringEncoder");
props.put("request.required.acks", "1");
+ props.put("retry.backoff.ms",1000);
ProducerConfig config = new ProducerConfig(props);