Repository: incubator-gearpump Updated Branches: refs/heads/master 50316ce31 -> a47e1a6db
[GEARPUMP-328] FetchThread fetchSleepMS from Int to Long currently *KafkaConfig.FETCH_SLEEP_MS_CONFIG* is a INT parameter , move it into a LONG parameter is better . Author: darionyaphet <[email protected]> Closes #199 from darionyaphet/GEARPUMP-328. Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/a47e1a6d Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/a47e1a6d Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/a47e1a6d Branch: refs/heads/master Commit: a47e1a6dbe2ab594a891f48b2bb4f32b613f1b22 Parents: 50316ce Author: darionyaphet <[email protected]> Authored: Tue Jul 25 13:23:14 2017 +0800 Committer: manuzhang <[email protected]> Committed: Tue Jul 25 13:23:42 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java | 2 +- .../gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/a47e1a6d/external/kafka/src/main/java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java ---------------------------------------------------------------------- diff --git a/external/kafka/src/main/java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java b/external/kafka/src/main/java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java index 451faec..cd9abe0 100644 --- a/external/kafka/src/main/java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java +++ b/external/kafka/src/main/java/org/apache/gearpump/streaming/kafka/util/KafkaConfig.java @@ -142,7 +142,7 @@ public class KafkaConfig extends AbstractConfig implements Serializable { ConfigDef.Importance.LOW, FETCH_THRESHOLD_DOC) .define(FETCH_SLEEP_MS_CONFIG, - ConfigDef.Type.INT, + ConfigDef.Type.LONG, 100, ConfigDef.Range.atLeast(0), ConfigDef.Importance.LOW, http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/a47e1a6d/external/kafka/src/main/scala/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala ---------------------------------------------------------------------- diff --git a/external/kafka/src/main/scala/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala b/external/kafka/src/main/scala/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala index 49c116c..0cf4191 100644 --- a/external/kafka/src/main/scala/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala +++ b/external/kafka/src/main/scala/org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.scala @@ -36,7 +36,7 @@ object FetchThread { class FetchThreadFactory extends java.io.Serializable { def getFetchThread(config: KafkaConfig, client: KafkaClient): FetchThread = { val fetchThreshold = config.getInt(KafkaConfig.FETCH_THRESHOLD_CONFIG) - val fetchSleepMS = config.getInt(KafkaConfig.FETCH_SLEEP_MS_CONFIG) + val fetchSleepMS = config.getLong(KafkaConfig.FETCH_SLEEP_MS_CONFIG) val startOffsetTime = config.getLong(KafkaConfig.CONSUMER_START_OFFSET_CONFIG) FetchThread(fetchThreshold, fetchSleepMS, startOffsetTime, client) }
