diff --git a/src/kinesis_lambda_es.js b/src/kinesis_lambda_es.js
index c042c46..367d241 100644
--- a/src/kinesis_lambda_es.js
+++ b/src/kinesis_lambda_es.js
@@ -57,6 +57,7 @@ function postToES(doc, context) {
     req.region = esDomain.region;
     req.headers['presigned-expires'] = false;
     req.headers['Host'] = endpoint.host;
+    req.headers['Content-Type'] = "application/json";
     req.body = doc;
 
     var signer = new AWS.Signers.V4(req , 'es');  // es: service code