post merge fix

AbsaOSS · Oct 23, 2024 · 2b182a5 · 2b182a5
1 parent d5571c5
commit 2b182a5
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/examples/src/main/scala/za/co/absa/kafkacase/examples/KafkaCase.scala b/examples/src/main/scala/za/co/absa/kafkacase/examples/KafkaCase.scala
@@ -18,8 +18,8 @@ package za.co.absa.kafkacase.examples
 
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.clients.producer.ProducerConfig
-import za.co.absa.kafkacase.examples.reader.{ReaderCustomResourceHandling, ReaderManualResourceHandling, ReaderUsingsResourceHandling}
-import za.co.absa.kafkacase.examples.writer.{WriterCustomResourceHandling, WriterManualResourceHandling, WriterUsingsResourceHandling}
+import za.co.absa.kafkacase.examples.reader.{ReaderCustomResourceHandling, ReaderManualResourceHandling, ReaderReadOnce, ReaderUsingsResourceHandling}
+import za.co.absa.kafkacase.examples.writer.{WriterCustomResourceHandling, WriterManualResourceHandling, WriterUsingsResourceHandling, WriterWriteOnce}
 import za.co.absa.kafkacase.models.topics.EdlaChange
 
 import java.util.{Properties, UUID}

diff --git a/.../kafkacase/examples/reader/ReadOnce.scala → ...case/examples/reader/ReaderReadOnce.scala b/.../kafkacase/examples/reader/ReadOnce.scala → ...case/examples/reader/ReaderReadOnce.scala
@@ -21,7 +21,7 @@ import za.co.absa.kafkacase.reader.Reader
 
 import java.util.Properties
 
-object ReadOnce {
+object ReaderReadOnce {
   def apply[T: Decoder](readerProps: Properties, topicName: String): Unit =
     Reader.readOnce[T](readerProps, topicName, println)
 }
diff --git a/...kafkacase/examples/writer/WriteOnce.scala → ...ase/examples/writer/WriterWriteOnce.scala b/...kafkacase/examples/writer/WriteOnce.scala → ...ase/examples/writer/WriterWriteOnce.scala
@@ -21,7 +21,7 @@ import za.co.absa.kafkacase.writer.Writer
 
 import java.util.Properties
 
-object WriteOnce {
+object WriterWriteOnce {
   def apply[T: Encoder](writerProps: Properties, topicName: String, sampleMessageToWrite: T): Unit =
     Writer.writeOnce(writerProps, topicName, "sampleKey", sampleMessageToWrite)
 }