diff --git a/src/main/java/se/yolean/kafka/keyvalue/Endpoints.java b/src/main/java/se/yolean/kafka/keyvalue/Endpoints.java index 37c245c..c315477 100644 --- a/src/main/java/se/yolean/kafka/keyvalue/Endpoints.java +++ b/src/main/java/se/yolean/kafka/keyvalue/Endpoints.java @@ -108,6 +108,7 @@ public void write(OutputStream out) throws IOException, WebApplicationException while (values.hasNext()) { out.write(values.next()); out.write('\n'); + out.flush(); } } };