diff --git a/http/ingest.go b/http/ingest.go index 98821661581532d2b194a103b053c2d89d99ea5c..4226413a5c732e1784e73c6afba91bdb266019be 100644 --- a/http/ingest.go +++ b/http/ingest.go @@ -130,17 +130,13 @@ func (s *IngestServer) IngestHandler(w http.ResponseWriter, req *http.Request) { return } - n, err := s.ingestBatch(req.Body) + _, err := s.ingestBatch(req.Body) if err != nil { log.Printf("ingestion error: %v", err) http.Error(w, err.Error(), http.StatusInternalServerError) return } - if n > 0 { - log.Printf("received %d records", n) - } - w.WriteHeader(http.StatusAccepted) }