fix: Conflicting KV create (#5635)

kubeshop · Jul 4, 2024 · 5597434 · 5597434
1 parent 678df05
commit 5597434
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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).