Refactoring Kafka

Resolving bugs - validating configurations and closing consumer in the shutdown
siddhi-io · Jun 22, 2017 · 7200138 · 7200138
1 parent c562d2f
commit 7200138
Show file tree

Hide file tree

Showing 18 changed files with 2,750 additions and 1,191 deletions.
diff --git a/.gitignore b/.gitignore
@@ -18,5 +18,10 @@
 *.tar.gz
 *.rar
 
+tmp_kafka*
+.idea
+target
+*.iml
+.DS_Store
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
diff --git a/...-transport/src/main/java/org/wso2/siddhi/extension/input/transport/kafka/KafkaSource.java b/...-transport/src/main/java/org/wso2/siddhi/extension/input/transport/kafka/KafkaSource.java