Skip to content

Commit 2b182a5

Browse files
committed
post merge fix
1 parent d5571c5 commit 2b182a5

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

examples/src/main/scala/za/co/absa/kafkacase/examples/KafkaCase.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,8 @@ package za.co.absa.kafkacase.examples
1818

1919
import org.apache.kafka.clients.consumer.ConsumerConfig
2020
import org.apache.kafka.clients.producer.ProducerConfig
21-
import za.co.absa.kafkacase.examples.reader.{ReaderCustomResourceHandling, ReaderManualResourceHandling, ReaderUsingsResourceHandling}
22-
import za.co.absa.kafkacase.examples.writer.{WriterCustomResourceHandling, WriterManualResourceHandling, WriterUsingsResourceHandling}
21+
import za.co.absa.kafkacase.examples.reader.{ReaderCustomResourceHandling, ReaderManualResourceHandling, ReaderReadOnce, ReaderUsingsResourceHandling}
22+
import za.co.absa.kafkacase.examples.writer.{WriterCustomResourceHandling, WriterManualResourceHandling, WriterUsingsResourceHandling, WriterWriteOnce}
2323
import za.co.absa.kafkacase.models.topics.EdlaChange
2424

2525
import java.util.{Properties, UUID}

examples/src/main/scala/za/co/absa/kafkacase/examples/reader/ReadOnce.scala renamed to examples/src/main/scala/za/co/absa/kafkacase/examples/reader/ReaderReadOnce.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import za.co.absa.kafkacase.reader.Reader
2121

2222
import java.util.Properties
2323

24-
object ReadOnce {
24+
object ReaderReadOnce {
2525
def apply[T: Decoder](readerProps: Properties, topicName: String): Unit =
2626
Reader.readOnce[T](readerProps, topicName, println)
2727
}

examples/src/main/scala/za/co/absa/kafkacase/examples/writer/WriteOnce.scala renamed to examples/src/main/scala/za/co/absa/kafkacase/examples/writer/WriterWriteOnce.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import za.co.absa.kafkacase.writer.Writer
2121

2222
import java.util.Properties
2323

24-
object WriteOnce {
24+
object WriterWriteOnce {
2525
def apply[T: Encoder](writerProps: Properties, topicName: String, sampleMessageToWrite: T): Unit =
2626
Writer.writeOnce(writerProps, topicName, "sampleKey", sampleMessageToWrite)
2727
}

0 commit comments

Comments
 (0)