fix: 使用合法的 JetStream consumer 名称

2026-09-25 18:41:47 +00:00
parent 6ea78d4704
commit 1f9577c816
2 changed files with 7 additions and 3 deletions
@@ -186,9 +186,13 @@ func OpenConsumer(ctx context.Context, manager consumerManager, stream, subjectB
 		return nil, err
 	}
 	key := placement.Key()
+	// JetStream consumer names may not contain dots even though subjects do.
+	// Keep the placement subject hierarchical while using a stable, legal name
+	// for the durable cursor.
+	consumerName := strings.ReplaceAll(key, ".", "-")
 	consumer, err := manager.CreateOrUpdateConsumer(ctx, stream, jetstream.ConsumerConfig{
-		Name:          key,
-		Durable:       key,
+		Name:          consumerName,
+		Durable:       consumerName,
 		FilterSubject: strings.TrimSuffix(subjectBase, ".") + "." + key,
 		AckPolicy:     jetstream.AckExplicitPolicy,
 		AckWait:       5 * time.Minute,