diff --git a/http/consumer.go b/http/consumer.go
index <HASH>..<HASH> 100644
--- a/http/consumer.go
+++ b/http/consumer.go
@@ -15,7 +15,7 @@ func newConsumer(resp http.ResponseWriter) (*consumer, error) {
     if err != nil {
         return nil, err
     }
-    conn.Write([]byte("HTTP/1.1 200 OK\nContent-Type: text/event-stream\n\n"))
+    conn.Write([]byte("HTTP/1.1 200 OK\nContent-Type: text/event-stream\nX-Accel-Buffering: no\n\n"))
 
     return &consumer{conn, make(chan bool)}, nil
 }
Turn off nginx buffering (closes #2)