[1/2] camel git commit: CAMEL-8172 Enable multiple consumers for kafka endpoint with thanks to Ivan

[ningjiang]

Repository: camel
Updated Branches:
  refs/heads/camel-2.13.x e8aec2d5b -> 785cbc8cd
  refs/heads/camel-2.14.x 2bb612837 -> a3ae12f29


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/a3ae12f2
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a3ae12f2
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a3ae12f2

Branch: refs/heads/camel-2.14.x
Commit: a3ae12f291909f7cdf33ae809e63929d8b17ce44
Parents: 2bb6128
Author: Willem Jiang <willem.ji...@gmail.com>
Authored: Thu Jan 29 20:45:36 2015 +0800
Committer: Willem Jiang <willem.ji...@gmail.com>
Committed: Thu Jan 29 22:03:04 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/a3ae12f2/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;
+    }
 }