diff --git a/simple_elasticsearch/management/commands/es_manage.py b/simple_elasticsearch/management/commands/es_manage.py
index <HASH>..<HASH> 100644
--- a/simple_elasticsearch/management/commands/es_manage.py
+++ b/simple_elasticsearch/management/commands/es_manage.py
@@ -5,6 +5,17 @@ from django.core.management.base import BaseCommand, CommandError
 from ...utils import get_indices, create_indices, rebuild_indices
 
 
+class Unbuffered(object):
+    def __init__(self, stream):
+        self.stream = stream
+    def write(self, data):
+        self.stream.write(data)
+        self.stream.flush()
+    def __getattr__(self, attr):
+        return getattr(self.stream, attr)
+sys.stdout = Unbuffered(sys.stdout)
+
+
 class ESCommandError(CommandError):
     pass
Adding a 'flushing' sys.stdout wrapper to help with some command line text output.