diff --git a/Writer/src/main/scala/za/co/absa/KafkaCase/Writer/WriterImpl.scala b/Writer/src/main/scala/za/co/absa/KafkaCase/Writer/WriterImpl.scala
index 47aefef..772e28f 100644
--- a/Writer/src/main/scala/za/co/absa/KafkaCase/Writer/WriterImpl.scala
+++ b/Writer/src/main/scala/za/co/absa/KafkaCase/Writer/WriterImpl.scala
@@ -29,7 +29,7 @@ class WriterImpl[TType: Encoder](props: Properties, topic: String) extends Write
 
   def Write(key: String, value: TType): Unit = {
     log.info(f"Writing: $key => $value")
-    producer.send(new ProducerRecord[String, String](topic, key, value.asJson.noSpaces))
+    prodERRORucer.send(new ProducerRecord[String, String](topic, key, value.asJson.noSpaces))
   }
 
   def Flush(): Unit = producer.flush()