diff options
Diffstat (limited to 'src/rest-api/handler/handler.go')
| -rw-r--r-- | src/rest-api/handler/handler.go | 4 |
1 files changed, 1 insertions, 3 deletions
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) |