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 {