fix: 保持后端 assignment 可重试

2026-09-21 08:42:01 +00:00
parent ace84373f6
commit c1d0f4cec2
2 changed files with 1 additions and 2 deletions
@@ -167,7 +167,6 @@ func OpenConsumer(ctx context.Context, manager consumerManager, stream, subjectB
 		AckPolicy:     jetstream.AckExplicitPolicy,
 		AckWait:       5 * time.Minute,
 		MaxAckPending: capacity,
-		MaxDeliver:    20,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("open %s assignment consumer: %w", backend, err)