Switch AutoOffsetReset definition

nomisRev · Oct 7, 2023 · 39e1785 · 39e1785
1 parent ce75eab
commit 39e1785
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/kotlin/io/github/nomisRev/kafka/Consumer.kt b/src/main/kotlin/io/github/nomisRev/kafka/Consumer.kt
@@ -263,9 +263,8 @@ public fun <K, V> KafkaConsumer<K, V>.subscribeTo(
     "io.github.nomisRev.kafka.receiver.AutoOffsetReset"
   )
 )
-public enum class AutoOffsetReset(public val value: String) {
-  Earliest("earliest"), Latest("latest"), None("none")
-}
+public typealias AutoOffsetReset =
+  io.github.nomisRev.kafka.receiver.AutoOffsetReset
 
 /** Default values taken from [org.apache.kafka.clients.consumer.ConsumerConfig] */
 @Deprecated(

diff --git a/src/main/kotlin/io/github/nomisRev/kafka/receiver/ReceiverSettings.kt b/src/main/kotlin/io/github/nomisRev/kafka/receiver/ReceiverSettings.kt
@@ -13,8 +13,9 @@ private const val DEFAULT_MAX_COMMIT_ATTEMPTS = 100
 private val DEFAULT_COMMIT_RETRY_INTERVAL = 500.milliseconds
 private val DEFAULT_COMMIT_INTERVAL = 5.seconds
 
-public typealias AutoOffsetReset =
-  io.github.nomisRev.kafka.AutoOffsetReset
+public enum class AutoOffsetReset(public val value: String) {
+  Earliest("earliest"), Latest("latest"), None("none")
+}
 
 /**
  * A data class that exposes configuration for [KafkaReceiver],