We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bf2f28e commit b4d736dCopy full SHA for b4d736d
1 file changed
internal/utils/nats_test.go
@@ -61,7 +61,5 @@ func sharedConsumerConfig(name string, subjects []string) jetstream.ConsumerConf
61
return jetstream.ConsumerConfig{
62
Name: name,
63
FilterSubjects: subjects,
64
- AckPolicy: jetstream.AckExplicitPolicy,
65
- MaxAckPending: 1,
66
}
67
0 commit comments