From 55974340b2a2c6ed0e067e31dbb9c519c36a8450 Mon Sep 17 00:00:00 2001 From: Jacek Wysocki Date: Thu, 4 Jul 2024 16:41:48 +0200 Subject: [PATCH] fix: Conflicting KV create (#5635) --- cmd/logs-server/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/logs-server/main.go b/cmd/logs-server/main.go index 295d1ca8ead..9a8f71982bf 100644 --- a/cmd/logs-server/main.go +++ b/cmd/logs-server/main.go @@ -82,7 +82,7 @@ func main() { log.Warnw("error setting expiration policy", "error", err) } - kv := Must(js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: cfg.KVBucketName})) + kv := Must(js.CreateOrUpdateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: cfg.KVBucketName})) state := state.NewState(kv) svc := logs.NewLogsService(nc, js, state, logStream).