From 951675d62f631df7ccaca7c22de004d9576d3e91 Mon Sep 17 00:00:00 2001 From: Baitinq Date: Mon, 27 May 2024 18:45:50 +0200 Subject: payload-processor: insert to the file table --- src/rest-api/handler/handler.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) (limited to 'src/rest-api/handler') diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go index 3454486..9e44612 100644 --- a/src/rest-api/handler/handler.go +++ b/src/rest-api/handler/handler.go @@ -27,14 +27,12 @@ func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { log.Fatal(err) } - body := fmt.Sprint("Hello World!", r.RemoteAddr, string(bytes)) - ctx, cancel := context.WithTimeout(r.Context(), 5*time.Second) defer cancel() err = h.kafka_writer.WriteMessages(ctx, kafka.Message{ Key: []byte("key"), //TODO:This routes to a partition. We should probably route by agent UUID TODO: wont this negate having multiple topics - Value: []byte(body), + Value: bytes, }) if err != nil { log.Fatal(err) -- cgit 1.4.1