diff --git a/src/main/scala/adapters/kafka/ProducerImpl.scala b/src/main/scala/adapters/kafka/ProducerImpl.scala
index f89e2ec..f83152e 100644
--- a/src/main/scala/adapters/kafka/ProducerImpl.scala
+++ b/src/main/scala/adapters/kafka/ProducerImpl.scala
@@ -48,7 +48,7 @@ class ProducerImpl(
           System.exit(-5)
         }
 
-        return IO.raiseError(e)
+        IO.raiseError(e)
       })
 
   override def healthy(): IO[Boolean] = {