Update to Kafka 0.8.1
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e2d549d5 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e2d549d5 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e2d549d5 Branch: refs/heads/camel-2.13.x Commit: e2d549d5fdd391e2f950e4a8f2406240f457ea7b Parents: 2249559 Author: Fabien Chaillou <[email protected]> Authored: Wed Mar 26 14:11:41 2014 -0400 Committer: Claus Ibsen <[email protected]> Committed: Thu Mar 27 08:05:48 2014 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/kafka/KafkaEndpointTest.java | 6 +++++- .../org/apache/camel/component/kafka/SimplePartitioner.java | 4 ++-- parent/pom.xml | 4 ++-- 3 files changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e2d549d5/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java index 3a59e3e..6ac6f81 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java @@ -18,8 +18,10 @@ package org.apache.camel.component.kafka; import java.net.URISyntaxException; +import kafka.message.Message; import kafka.message.MessageAndMetadata; +import kafka.serializer.DefaultDecoder; import org.apache.camel.Exchange; import org.junit.Test; @@ -32,8 +34,10 @@ public class KafkaEndpointTest { public void testCreatingKafkaExchangeSetsHeaders() throws URISyntaxException { KafkaEndpoint endpoint = new KafkaEndpoint("kafka:localhost", "localhost", new KafkaComponent()); + Message message = new Message("mymessage".getBytes(), "somekey".getBytes()); + DefaultDecoder decoder = new DefaultDecoder(null); MessageAndMetadata<byte[], byte[]> mm = - new MessageAndMetadata<byte[], byte[]>("somekey".getBytes(), "mymessage".getBytes(), "topic", 4, 56); + new MessageAndMetadata<byte[], byte[]>("topic", 4, message, 56, decoder, decoder); Exchange exchange = endpoint.createKafkaExchange(mm); assertEquals("somekey", exchange.getIn().getHeader(KafkaConstants.KEY)); http://git-wip-us.apache.org/repos/asf/camel/blob/e2d549d5/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/SimplePartitioner.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/SimplePartitioner.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/SimplePartitioner.java index 05eb1e5..039a2e7 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/SimplePartitioner.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/SimplePartitioner.java @@ -19,7 +19,7 @@ package org.apache.camel.component.kafka; import kafka.producer.Partitioner; import kafka.utils.VerifiableProperties; -public class SimplePartitioner implements Partitioner<String> { +public class SimplePartitioner implements Partitioner { public SimplePartitioner(VerifiableProperties props) { } @@ -31,7 +31,7 @@ public class SimplePartitioner implements Partitioner<String> { * @return an integer between 0 and numPartitions-1 */ @Override - public int partition(String key, int numPartitions) { + public int partition(Object key, int numPartitions) { return key.hashCode() % numPartitions; } http://git-wip-us.apache.org/repos/asf/camel/blob/e2d549d5/parent/pom.xml ---------------------------------------------------------------------- diff --git a/parent/pom.xml b/parent/pom.xml index ffc9e3d..f57d34e 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -253,8 +253,8 @@ <junit-bundle-version>4.11_1</junit-bundle-version> <junit-version>4.11</junit-version> <jython-version>2.5.3</jython-version> - <kafka-version>0.8.0</kafka-version> - <kafka-bundle-version>0.8.0_1</kafka-bundle-version> + <kafka-version>0.8.1</kafka-version> + <kafka-bundle-version>0.8.1_1</kafka-bundle-version> <karaf-version>2.3.3</karaf-version> <kie-version>6.0.0.Final</kie-version> <krati-version>0.4.9</krati-version>
