You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/01/29 15:04:45 UTC
[2/2] camel git commit: CAMEL-8172 Enable multiple consumers for
kafka endpoint with thanks to Ivan
CAMEL-8172 Enable multiple consumers for kafka endpoint with thanks to Ivan
Conflicts:
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/785cbc8c
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/785cbc8c
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/785cbc8c
Branch: refs/heads/camel-2.13.x
Commit: 785cbc8cd3dbcf0619172161e489fd9599576a03
Parents: e8aec2d
Author: Willem Jiang <wi...@gmail.com>
Authored: Thu Jan 29 20:45:36 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Thu Jan 29 22:03:51 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaEndpoint.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/785cbc8c/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
index af1bcd1..c747a7f 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
@@ -23,6 +23,7 @@ import kafka.message.MessageAndMetadata;
import org.apache.camel.Consumer;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
+import org.apache.camel.MultipleConsumersSupport;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
@@ -32,7 +33,7 @@ import org.apache.camel.impl.DefaultMessage;
/**
*
*/
-public class KafkaEndpoint extends DefaultEndpoint {
+public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersSupport {
private String brokers;
private KafkaConfiguration configuration = new KafkaConfiguration();
@@ -426,4 +427,8 @@ public class KafkaEndpoint extends DefaultEndpoint {
return configuration.getRequestTimeoutMs();
}
+ @Override
+ public boolean isMultipleConsumersSupported() {
+ return true;
+ }
}