From 1df12c4e5d665fbdf852110f2bcf641c79c88f1c Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Wed, 6 Mar 2019 09:49:21 +0100 Subject: [PATCH] Try flush after each record to see if it makes any difference Probably it won't, according to https://stackoverflow.com/questions/34030904/calling-flush-on-jersey-streamingoutput-has-no-effect Pushed as sha256:df921d7abc4862e4c08f9d754a8d87e2ab50842fd913813349bbdea3de29729e --- src/main/java/se/yolean/kafka/keyvalue/Endpoints.java | 1 + 1 file changed, 1 insertion(+) 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(); } } };