deliberately made buggy writer

AbsaOSS · Aug 22, 2024 · 6361872 · 6361872
1 parent 1e4bf2e
commit 6361872
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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()