From eb1a48912b1f97099a310cbc456a85bef7125d24 Mon Sep 17 00:00:00 2001 From: Baitinq Date: Sat, 4 May 2024 22:06:57 +0200 Subject: misc: add todo --- src/rest-api/handler/handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/rest-api/handler') diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go index 8985b43..3fdd3f8 100644 --- a/src/rest-api/handler/handler.go +++ b/src/rest-api/handler/handler.go @@ -33,7 +33,7 @@ func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { defer cancel() err = h.kafka_writer.WriteMessages(ctx, kafka.Message{ - Key: []byte("key-A"), + Key: []byte("key-A"), //TODO: This routes to a partition. We should probably route by agent UUID Value: []byte(body), }) if err != nil { -- cgit 1.4.1