Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48920130
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,326 @@
+/**
+ * Licensed to the Apa
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48918567
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,500 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48918465
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,500 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48918303
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,500 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48917236
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,500 @@
+/**
+ * Licensed to
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48877262
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,512 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48647206
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,512 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48647193
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,512 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48647169
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,378 @@
+/**
+ * Licensed to the Apa
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48646958
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,378 @@
+/**
+ * Licensed to the Apa
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48646883
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,512 @@
+/**
+ * Licensed to
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48507270
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,408 @@
+/**
+ * Licensed to the Ap
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48507106
--- Diff:
kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java ---
@@ -0,0 +1,221 @@
+/**
+ * Licensed to the
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452313
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,408 @@
+/**
+ * Licensed to the Apa
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452301
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,455 @@
+/**
+ * Licensed to
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452288
--- Diff:
kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java ---
@@ -0,0 +1,221 @@
+/**
+ * Licensed to the A
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452284
--- Diff:
kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java ---
@@ -0,0 +1,221 @@
+/**
+ * Licensed to the A
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452276
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,408 @@
+/**
+ * Licensed to the Apa
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48452268
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaConsumerWrapper.java ---
@@ -0,0 +1,408 @@
+/**
+ * Licensed to the Apa
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48380261
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,276 @@
+/**
+ * License
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48379994
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,276 @@
+/**
+ * Licensed to th
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48379780
--- Diff: kafka/pom.xml ---
@@ -0,0 +1,235 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instan
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48378389
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,455 @@
+/**
+ * Licensed to
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48373578
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,455 @@
+/**
+ * Licen
Github user gauravgopi123 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48373387
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,276 @@
+/**
+ * License
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48075562
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48075108
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,277 @@
+/**
+ * Licensed t
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48061524
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * License
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r48060846
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,277 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47985081
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47984961
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47984778
--- Diff: kafka/pom.xml ---
@@ -0,0 +1,278 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instan
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47983322
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47983102
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47982758
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47982383
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,277 @@
+/**
+ * Licensed t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47979259
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,277 @@
+/**
+ * Licensed t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47979129
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaPartitioner.java
---
@@ -0,0 +1,277 @@
+/**
+ * Licensed t
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47961164
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47961214
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47961112
--- Diff:
kafka/src/main/java/com/datatorrent/contrib/kafka090/AbstractKafkaInputOperator.java
---
@@ -0,0 +1,410 @@
+/**
+ * Licensed
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47960957
--- Diff: kafka/pom.xml ---
@@ -0,0 +1,278 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instan
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47960858
--- Diff: kafka/pom.xml ---
@@ -0,0 +1,278 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instan
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/134#discussion_r47960735
--- Diff: kafka/pom.xml ---
@@ -0,0 +1,278 @@
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instan
GitHub user siyuanh opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/134
New Kafka input operator using 0.9.0 Kafka consumer API
Some highlights of the operator
1. Out-of-box One-to-one and one-to-many partition scheme support plus
customizable partit
45 matches
Mail list logo
