diff --git a/metadata/service/server/amqp/router.yml b/metadata/service/server/amqp/router.yml
index 99b541a..6f55f4d 100644
--- a/metadata/service/server/amqp/router.yml
+++ b/metadata/service/server/amqp/router.yml
@@ -38,8 +38,10 @@
           engine: elasticsearch
           host: ${_param:heka_router_output_host}
           port: 9200
-          encoder: es_json
+          encoder: es_payload
           message_matcher: "Logger != 'hekad'"
+          flush_count: 10
+          flush_interval: 1000
         dashboard01:
           engine: dashboard
           ticker_interval: 30