diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py
index 152fa162..ad01585c 100644
--- a/confluent_server/confluent/consoleserver.py
+++ b/confluent_server/confluent/consoleserver.py
@@ -73,7 +73,10 @@ def get_buffer_output(nodename):
         out.flush()
         select.select((instream,), (), (), 30)
         while not outdata or outdata[-1]:
-            chunk = instream.read(128)
+            try:
+                chunk = instream.read(128)
+            except IOError:
+                chunk = None
             if chunk:
                 outdata.extend(chunk)
             else: