Repository: camel Updated Branches: refs/heads/camel-2.17.x b8564967b -> 414be8407
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/414be840 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/414be840 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/414be840 Branch: refs/heads/camel-2.17.x Commit: 414be84070c943dc1eebe32e251e2d427ddec474 Parents: b856496 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:52:45 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/414be840/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 db99a09..5c1bcab 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 @@ -19,8 +19,8 @@ package org.apache.camel.component.kafka; public final class KafkaConstants { 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";
