diff options
| author | Baitinq <[email protected]> | 2024-05-04 22:06:57 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-05-04 22:08:57 +0200 |
| commit | eb1a48912b1f97099a310cbc456a85bef7125d24 (patch) | |
| tree | 5f1d3ddc6863bd398f48f4d60a0e0d3dc3364a0e | |
| parent | misc: kafka: set default number of partitions to 2 (diff) | |
| download | fs-tracer-backend-eb1a48912b1f97099a310cbc456a85bef7125d24.tar.gz fs-tracer-backend-eb1a48912b1f97099a310cbc456a85bef7125d24.tar.bz2 fs-tracer-backend-eb1a48912b1f97099a310cbc456a85bef7125d24.zip | |
misc: add todo
| -rw-r--r-- | TODO | 2 | ||||
| -rw-r--r-- | src/rest-api/handler/handler.go | 2 |
2 files changed, 1 insertions, 3 deletions
diff --git a/TODO b/TODO index 5ac71b0..dd1ff00 100644 --- a/TODO +++ b/TODO @@ -1,4 +1,2 @@ -helmsfile o algo asi kafka UI nixos-k3s repo -klipper-lb 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 { |