diff options
Diffstat (limited to 'src/rest-api/handler/handler.go')
| -rw-r--r-- | src/rest-api/handler/handler.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go index 3fdd3f8..3454486 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"), //TODO: This routes to a partition. We should probably route by agent UUID + 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), }) if err != nil { |