Merge pull request #189 from nomisRev/stressTest

Incosistent Acks
nomisRev · Apr 8, 2024 · 40f00d3 · 40f00d3
2 parents be52f8a + 09d5080
commit 40f00d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/kotlin/io/github/nomisRev/kafka/publisher/PublisherSettings.kt b/src/main/kotlin/io/github/nomisRev/kafka/publisher/PublisherSettings.kt
@@ -31,7 +31,7 @@ public data class PublisherSettings<Key, Value>(
   val bootstrapServers: String,
   val keySerializer: Serializer<Key>,
   val valueSerializer: Serializer<Value>,
-  val acknowledgments: Acks = Acks.One,
+  val acknowledgments: Acks = Acks.All,
   val closeTimeout: Duration = Duration.INFINITE,
   val isFatal: (t: Throwable) -> Boolean =
     { it is AuthenticationException || it is ProducerFencedException },