flush

mc-b · Jan 19, 2020 · 598db8e · 598db8e
1 parent 914c791
commit 598db8e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/ch/mc_b/iot/kafka/CSVConsumer.java b/src/main/java/ch/mc_b/iot/kafka/CSVConsumer.java
@@ -50,6 +50,7 @@ public static void main(String[] args) throws Exception
                 {
                     System.out.printf( "offset = %d, value = %s%n", offset, record.value() );
                     writer.printf( "%s%n", record.value() );
+                    writer.flush();
                 }
             }
         }