diff --git a/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala b/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala
index ab2122987..523f29bc9 100644
--- a/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala
+++ b/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala
@@ -44,7 +44,7 @@ class NsqSink[F[_]: Sync] private (
   topicName: String,
 ) extends Sink[F] {
 
-  var healthStatus = true
+  @volatile private var healthStatus = true
 
   override def isHealthy: F[Boolean] = Sync[F].pure(healthStatus)