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 <anco...@gmail.com> Authored: Wed Jul 20 13:51:28 2016 +0200 Committer: Andrea Cosentino <anco...@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";
