diff --git a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb
index 91fd59e..b388900 100644
--- a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb
+++ b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb
@@ -71,6 +71,11 @@ def write(chunk)
     end
 
     request.body = bulk_message.join("\n")
+
+    request.body.gsub!(/\\"/, '"')
+    request.body.gsub!(/\"{/, '{')
+    request.body.gsub!(/}\"/, '}')
+
     http.request(request).value
   end
 end