Merge pull request #301 from ramindu90/master

Removing continuous commit logs
siddhi-io · Mar 29, 2017 · c1c8bc0 · c1c8bc0
2 parents 2b529a6 + fef3688
commit c1c8bc0
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...rt/src/main/java/org/wso2/siddhi/extension/input/transport/kafka/KafkaConsumerThread.java b/...rt/src/main/java/org/wso2/siddhi/extension/input/transport/kafka/KafkaConsumerThread.java
@@ -107,9 +107,11 @@ public void run() {
                     sourceEventListener.onEvent(event);
                 }
                 try {
-                    consumer.commitAsync();
+                    if (!records.isEmpty()) {
+                        consumer.commitAsync();
+                    }
                 } catch (CommitFailedException e) {
-                    log.error("Kafka commit failed for topic/s" + Arrays.toString(topics), e);
+                    log.error("Kafka commit failed for topic kafka_result_topic", e);
                 }
             }
             try {