Fix Dlq production exception handler unit tests (#123)

michelin · Nov 6, 2023 · 2b0dbb4 · 2b0dbb4
1 parent 94d009f
commit 2b0dbb4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...core/src/test/java/com/michelin/kstreamplify/error/DlqProductionExceptionHandlerTest.java b/...core/src/test/java/com/michelin/kstreamplify/error/DlqProductionExceptionHandlerTest.java
@@ -6,8 +6,6 @@
 
 import com.michelin.kstreamplify.avro.KafkaError;
 import com.michelin.kstreamplify.context.KafkaStreamsExecutionContext;
-import com.michelin.kstreamplify.error.DlqExceptionHandler;
-import com.michelin.kstreamplify.error.DlqProductionExceptionHandler;
 import io.confluent.kafka.serializers.KafkaAvroSerializer;
 import io.confluent.kafka.serializers.KafkaAvroSerializerConfig;
 import java.nio.charset.StandardCharsets;
@@ -99,7 +97,7 @@ void shouldConfigure() {
         configs.put("schema.registry.url", "localhost:8080");
         configs.put("acks", "all");
 
-        handler = new DlqProductionExceptionHandler();
+        handler = new DlqProductionExceptionHandler(null);
         handler.configure(configs);
 
         assertTrue(DlqExceptionHandler.getProducer() instanceof KafkaProducer<byte[], KafkaError>);