diff --git a/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java b/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
index 7d19f29..a21a41c 100644
--- a/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
+++ b/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
@@ -101,6 +101,7 @@
         ryaConfig.setAccumuloInstance( config.getClusterName() );
         ryaConfig.setAccumuloUser( config.getUsername() );
         ryaConfig.setAccumuloPassword( config.getPassword() );
+        ryaConfig.setFlush(false);
 
         // Create the Sail object.
         try {