From bf545378641e58ef7b8d7cb1fc77b2a7690735f6 Mon Sep 17 00:00:00 2001
From: Vladimir Dementyev <palkan@hey.com>
Date: Wed, 1 Nov 2023 15:25:50 -0700
Subject: [PATCH] fix: use no ack policy for jetstream consumers

---
 broker/nats.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/nats.go b/broker/nats.go
index 2b7332ba..13843963 100644
--- 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 {