Skip to content

Commit 31eacb3

Browse files
committed
Adjust ack policy
1 parent 1c2b9fa commit 31eacb3

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

python/nats-indexer.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ async def process(msg):
2222
))
2323

2424
add(prepared_search_docs)
25-
await msg.ack()
2625

2726

2827
async def run():
@@ -31,8 +30,10 @@ async def run():
3130

3231
await js.subscribe(
3332
config.NATS_STREAM_NAME,
34-
config=nats.js.api.ConsumerConfig(durable_name=config.NATS_CONSUMER_NAME),
33+
config=nats.js.api.ConsumerConfig(durable_name=config.NATS_CONSUMER_NAME,
34+
ack_policy=nats.js.api.AckPolicy.NONE),
3535
cb=process,
36+
manual_ack=False
3637
)
3738

3839

0 commit comments

Comments
 (0)