diff --git a/pkg/outputs/nats_outputs/jetstream/jetstream_output.go b/pkg/outputs/nats_outputs/jetstream/jetstream_output.go
index 34428d45..a7e2efad 100644
--- a/pkg/outputs/nats_outputs/jetstream/jetstream_output.go
+++ b/pkg/outputs/nats_outputs/jetstream/jetstream_output.go
@@ -490,7 +490,7 @@ func (n *jetstreamOutput) createNATSConn(c *config) (*nats.Conn, error) {
 		nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) {
 			n.logger.Printf("NATS error: %v", err)
 		}),
-		nats.DisconnectErrHandler(func(c *nats.Conn, err error) {
+		nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
 			n.logger.Printf("Disconnected from NATS err=%v", err)
 		}),
 		nats.ClosedHandler(func(*nats.Conn) {
diff --git a/pkg/outputs/nats_outputs/nats/nats_output.go b/pkg/outputs/nats_outputs/nats/nats_output.go
index 4f943a6a..407765d9 100644
--- a/pkg/outputs/nats_outputs/nats/nats_output.go
+++ b/pkg/outputs/nats_outputs/nats/nats_output.go
@@ -269,7 +269,7 @@ func (n *NatsOutput) createNATSConn(c *Config) (*nats.Conn, error) {
 		nats.ErrorHandler(func(_ *nats.Conn, _ *nats.Subscription, err error) {
 			n.logger.Printf("NATS error: %v", err)
 		}),
-		nats.DisconnectErrHandler(func(c *nats.Conn, err error) {
+		nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
 			n.logger.Printf("Disconnected from NATS err=%v", err)
 		}),
 		nats.ClosedHandler(func(*nats.Conn) {