fix(kafka): appearently spring-kafka changed the dead letter suffix

Trendyol · Nov 19, 2024 · 91af732 · 91af732
1 parent aad5382
commit 91af732
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...alone-example/src/test/kotlin/com/stove/spring/standalone/example/e2e/TestSystemConfig.kt b/...alone-example/src/test/kotlin/com/stove/spring/standalone/example/e2e/TestSystemConfig.kt
@@ -40,6 +40,7 @@ class TestSystemConfig : AbstractProjectConfig() {
         kafka {
           stoveKafkaObjectMapperRef = ObjectMapperConfig.createObjectMapperWithDefaults()
           KafkaSystemOptions(
+            topicSuffixes = TopicSuffixes().copy(error = listOf(".error", ".DLT", "dlt")),
             objectMapper = ObjectMapperConfig.createObjectMapperWithDefaults(),
             containerOptions = KafkaContainerOptions(tag = "latest") { }
           ) {