From 5b4a7b04d91b8d79a4f41cf0bdf7634c7fedaac8 Mon Sep 17 00:00:00 2001
From: Parham Alvani <parham.alvani@gmail.com>
Date: Sun, 6 Oct 2024 22:14:56 +0000
Subject: [PATCH] fix: remove ack from nats core

---
 internal/client/jetstream.go | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/internal/client/jetstream.go b/internal/client/jetstream.go
index 0d3ac0b..9f05fa7 100644
--- a/internal/client/jetstream.go
+++ b/internal/client/jetstream.go
@@ -385,10 +385,6 @@ func (client *Client) messageHandlerCoreFactory() (nats.MsgHandler, <-chan *Mess
 			Subject: msg.Subject,
 			Data:    msg.Data,
 		}
-
-		if err := msg.Ack(); err != nil {
-			client.logger.Error("Failed to acknowledge the message", zap.Error(err))
-		}
 	}, ch
 }