Merge pull request #58 from seznam/pete/no-sync-commit

#! [euphoria-kafka] No sync commit
seznam · Mar 24, 2017 · 1a02f6c · 1a02f6c
2 parents 849582f + d838bd9
commit 1a02f6c
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/euphoria-kafka/src/main/java/cz/seznam/euphoria/kafka/KafkaSource.java b/euphoria-kafka/src/main/java/cz/seznam/euphoria/kafka/KafkaSource.java
@@ -109,7 +109,6 @@ public void close() throws IOException {
 
     private void commitIfNeeded() {
       if (uncommittedCount > 0) {
-        c.commitSync();
         c.commitAsync();
         LOG.debug("Committed {} records.", uncommittedCount);
         uncommittedCount = 0;