Removing continuous commit logs

siddhi-io · Mar 29, 2017 · fef3688 · fef3688
1 parent 7dd50d8
commit fef3688
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 {