You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/01/21 10:09:06 UTC
camel git commit: Make Kafka KEY and PARTITION values more intuitive.
Repository: camel
Updated Branches:
refs/heads/master 890d561eb -> e23bf831a
Make Kafka KEY and PARTITION values more intuitive.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e23bf831
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e23bf831
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e23bf831
Branch: refs/heads/master
Commit: e23bf831a1ca0f60196c673ed07d75170a95e7bd
Parents: 890d561
Author: Aaron Riekenberg <aa...@target.com>
Authored: Wed Jan 20 08:45:12 2016 -0600
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Jan 21 10:06:26 2016 +0100
----------------------------------------------------------------------
.../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/e23bf831/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";