You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/04/08 13:21:16 UTC
camel git commit: CAMEL-9835: Enable kafka consumer to subcribe to
multiple topics
Repository: camel
Updated Branches:
refs/heads/master ea285f856 -> d7fc67fa1
CAMEL-9835: Enable kafka consumer to subcribe to multiple topics
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d7fc67fa
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d7fc67fa
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d7fc67fa
Branch: refs/heads/master
Commit: d7fc67fa16d083e570650aa20c064d609b469641
Parents: ea285f8
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Apr 8 12:56:52 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Apr 8 12:56:52 2016 +0200
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/kafka/KafkaConsumer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/d7fc67fa/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index ad02258..536ab66 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -103,7 +103,7 @@ public class KafkaConsumer extends DefaultConsumer {
int processed = 0;
try {
LOG.debug("Subscribing {} to topic {}", threadId, topicName);
- consumer.subscribe(Arrays.asList(topicName));
+ consumer.subscribe(Arrays.asList(topicName.split(",")));
if (endpoint.isSeekToBeginning()) {
LOG.debug("{} is seeking to the beginning on topic {}", threadId, topicName);