diff --git a/ee/backend/internal/db/datasaver/saver.go b/ee/backend/internal/db/datasaver/saver.go
index 76057309d..e05e502f1 100644
--- a/ee/backend/internal/db/datasaver/saver.go
+++ b/ee/backend/internal/db/datasaver/saver.go
@@ -19,7 +19,6 @@ func New(pg *cache.PGCache, cfg *db.Config) *Saver {
 	var producer types.Producer = nil
 	if cfg.UseQuickwit {
 		producer = queue.NewProducer(cfg.MessageSizeLimit, true)
-		defer producer.Close(15000)
 	}
 	return &Saver{pg: pg, producer: producer, topic: cfg.QuickwitTopic}
 }