You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/03/12 11:09:31 UTC
[2/3] camel git commit: CAMEL-10994: camel-kafka - Allow to configure
more options on component level
CAMEL-10994: camel-kafka - Allow to configure more options on component level
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bf2e963a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bf2e963a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bf2e963a
Branch: refs/heads/master
Commit: bf2e963a5907b09fc7b0584690ef22f8aa96972c
Parents: bd0dfe8
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Mar 12 12:08:57 2017 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Mar 12 12:08:57 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaComponentTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/bf2e963a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
index 92982cc..5a8af58 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
@@ -52,7 +52,7 @@ public class KafkaComponentTest {
String uri = "kafka:mytopic?partitioner=com.class.Party";
KafkaEndpoint endpoint = (KafkaEndpoint) kafka.createEndpoint(uri);
- assertEquals(null, endpoint.getConfiguration().getBrokers());
+ assertEquals("broker1:12345,broker2:12566", endpoint.getConfiguration().getBrokers());
assertEquals("broker1:12345,broker2:12566", endpoint.getComponent().getBrokers());
assertEquals("mytopic", endpoint.getConfiguration().getTopic());
assertEquals("com.class.Party", endpoint.getConfiguration().getPartitioner());