From f5580d363e7c9efffd8f521d36642928adee35c7 Mon Sep 17 00:00:00 2001
From: ramindu90 <ramindus@wso2.com>
Date: Fri, 23 Jun 2017 17:58:55 +0530
Subject: [PATCH] adding kafka io

---
 modules/distribution/pom.xml | 12 ++++++------
 pom.xml                      |  2 +-
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/modules/distribution/pom.xml b/modules/distribution/pom.xml
index d1a775a8..fc25951a 100644
--- a/modules/distribution/pom.xml
+++ b/modules/distribution/pom.xml
@@ -272,12 +272,12 @@
                                     <version>${siddhi.io.tcp.version}</version>
                                     <type>jar</type>
                                 </artifactItem>
-                                <!--<artifactItem>-->
-                                    <!--<groupId>org.wso2.extension.siddhi.io.kafka</groupId>-->
-                                    <!--<artifactId>siddhi-io-kafka</artifactId>-->
-                                    <!--<version>${siddhi.io.kafka.version}</version>-->
-                                    <!--<type>jar</type>-->
-                                <!--</artifactItem>-->
+                                <artifactItem>
+                                    <groupId>org.wso2.extension.siddhi.io.kafka</groupId>
+                                    <artifactId>siddhi-io-kafka</artifactId>
+                                    <version>${siddhi.io.kafka.version}</version>
+                                    <type>jar</type>
+                                </artifactItem>
                                 <!--<artifactItem>-->
                                     <!--<groupId>org.wso2.extension.siddhi.io.http</groupId>-->
                                     <!--<artifactId>siddhi-io-http</artifactId>-->
diff --git a/pom.xml b/pom.xml
index 2ec7e4c0..1d65a852 100644
--- a/pom.xml
+++ b/pom.xml
@@ -805,7 +805,7 @@
         <siddhi.execution.stat.version>1.0.0</siddhi.execution.stat.version>
         <siddhi.io.jms.version>1.0.2</siddhi.io.jms.version>
         <siddhi.io.tcp.version>1.0.0</siddhi.io.tcp.version>
-        <siddhi.io.kafka.version>1.0.0</siddhi.io.kafka.version>
+        <siddhi.io.kafka.version>4.0.0</siddhi.io.kafka.version>
         <siddhi.map.xml.version>4.0.0-M5</siddhi.map.xml.version>
         <siddhi.map.json.version>4.0.0</siddhi.map.json.version>
         <siddhi.store.mongodb.version>1.0.1</siddhi.store.mongodb.version>