You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by hu...@apache.org on 2017/11/01 22:36:04 UTC
incubator-gobblin git commit: [GOBBLIN-301] Fix the key
GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS
Repository: incubator-gobblin
Updated Branches:
refs/heads/master 603f22de0 -> 6f9acc073
[GOBBLIN-301] Fix the key GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS
Remove the org.apache prefix in the key name since
this is not a class name.
Closes #2156 from htran1/kafka_consumer_key_name
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/6f9acc07
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/6f9acc07
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/6f9acc07
Branch: refs/heads/master
Commit: 6f9acc07344e46f95908e566ae951f371b7cfb9f
Parents: 603f22d
Author: Hung Tran <hu...@linkedin.com>
Authored: Wed Nov 1 15:35:58 2017 -0700
Committer: Hung Tran <hu...@linkedin.com>
Committed: Wed Nov 1 15:35:58 2017 -0700
----------------------------------------------------------------------
.../apache/gobblin/source/extractor/extract/kafka/KafkaSource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/6f9acc07/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
index e1494f7..45223fb 100644
--- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
+++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java
@@ -102,7 +102,7 @@ public abstract class KafkaSource<S, D> extends EventBasedSource<S, D> {
public static final String ALL_TOPICS = "all";
public static final String AVG_RECORD_SIZE = "avg.record.size";
public static final String AVG_RECORD_MILLIS = "avg.record.millis";
- public static final String GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS = "org.apache.gobblin.kafka.consumerClient.class";
+ public static final String GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS = "gobblin.kafka.consumerClient.class";
public static final String GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION =
"gobblin.kafka.extract.allowTableTypeAndNamspaceCustomization";
public static final String DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS =