diff --git a/lib/perfdata/elasticsearchwriter.cpp b/lib/perfdata/elasticsearchwriter.cpp
index 029857094..2287365ef 100644
--- a/lib/perfdata/elasticsearchwriter.cpp
+++ b/lib/perfdata/elasticsearchwriter.cpp
@@ -25,6 +25,7 @@
 #include "icinga/compatutility.hpp"
 #include "icinga/service.hpp"
 #include "icinga/checkcommand.hpp"
+#include "base/defer.hpp"
 #include "base/tcpsocket.hpp"
 #include "base/stream.hpp"
 #include "base/base64.hpp"
@@ -441,6 +442,8 @@ void ElasticsearchWriter::SendRequest(const String& body)
 	if (!stream)
 		return;
 
+	Defer close ([&stream]() { stream->Close(); });
+
 	HttpRequest req(stream);
 
 	/* Specify required headers by Elasticsearch. */