You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/07/20 11:54:10 UTC
camel git commit: CAMEL-10157: Values in KafkaConstants don't fit
their variable name
Repository: camel
Updated Branches:
refs/heads/camel-2.16.x fca57bd33 -> 4203ed6a0
CAMEL-10157: Values in KafkaConstants don't fit their variable name
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4203ed6a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4203ed6a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4203ed6a
Branch: refs/heads/camel-2.16.x
Commit: 4203ed6a0b37fe64210acc062a682b5d182c3b04
Parents: fca57bd
Author: Andrea Cosentino <an...@gmail.com>
Authored: Wed Jul 20 13:51:28 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Wed Jul 20 13:53:03 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaConstants.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/4203ed6a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java
index 3397060..d3ff482 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConstants.java
@@ -24,8 +24,8 @@ public final class KafkaConstants {
public static final String DEFAULT_GROUP = "group1";
public static final String PARTITION_KEY = "kafka.PARTITION_KEY";
- public static final String PARTITION = "kafka.EXCHANGE_NAME";
- public static final String KEY = "kafka.CONTENT_TYPE";
+ public static final String PARTITION = "kafka.PARTITION";
+ public static final String KEY = "kafka.KEY";
public static final String TOPIC = "kafka.TOPIC";
public static final String OFFSET = "kafka.OFFSET";