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 <[email protected]> Authored: Wed Jan 20 08:45:12 2016 -0600 Committer: Claus Ibsen <[email protected]> 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";
