From 598db8e34cc916da024ea348380fa57f3620e616 Mon Sep 17 00:00:00 2001
From: mc-b <marcel.bernet@ch-open.ch>
Date: Sun, 19 Jan 2020 14:20:23 +0100
Subject: [PATCH] flush

---
 src/main/java/ch/mc_b/iot/kafka/CSVConsumer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/ch/mc_b/iot/kafka/CSVConsumer.java b/src/main/java/ch/mc_b/iot/kafka/CSVConsumer.java
index 50b242d..c048abc 100644
--- 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();
                 }
             }
         }