fix: use no ack policy for jetstream consumers

anycable · Nov 1, 2023 · bf54537 · bf54537
1 parent c8b0c4e
commit bf54537
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/nats.go b/broker/nats.go
@@ -363,7 +363,7 @@ func (n *NATS) addStreamConsumer(stream string) {
 
 	n.jconsumers.fetch(stream, func() (jetstream.Consumer, error) { // nolint:errcheck
 		cons, err := n.js.CreateConsumer(context.Background(), prefixedStream, jetstream.ConsumerConfig{
-			AckPolicy: jetstream.AckExplicitPolicy,
+			AckPolicy: jetstream.AckNonePolicy,
 		})
 
 		if err != nil {