gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hut...@apache.org
Subject incubator-gobblin git commit: [GOBBLIN-301] Fix the key GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS
Date Wed, 01 Nov 2017 22:36:04 GMT
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 <hutran@linkedin.com>
Authored: Wed Nov 1 15:35:58 2017 -0700
Committer: Hung Tran <hutran@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 =


Mime
View raw message