Repository: camel Updated Branches: refs/heads/master 16195cbdc -> 451eca81d
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/451eca81 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/451eca81 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/451eca81 Branch: refs/heads/master Commit: 451eca81daf0388fa97e9485aa06f8b038adaa36 Parents: 16195cb 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:51:28 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/451eca81/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 2bd4c4d..938cb28 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";
