From 2b0dbb4a1345163c7fcf2a8be26a9005fb277caf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lo=C3=AFc=20GREFFIER?= <loic.greffier_ext@michelin.com>
Date: Mon, 6 Nov 2023 22:31:31 +0100
Subject: [PATCH] Fix Dlq production exception handler unit tests (#123)

---
 .../kstreamplify/error/DlqProductionExceptionHandlerTest.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/kstreamplify-core/src/test/java/com/michelin/kstreamplify/error/DlqProductionExceptionHandlerTest.java b/kstreamplify-core/src/test/java/com/michelin/kstreamplify/error/DlqProductionExceptionHandlerTest.java
index 25e3d215..113c390d 100644
--- a/kstreamplify-core/src/test/java/com/michelin/kstreamplify/error/DlqProductionExceptionHandlerTest.java
+++ b/kstreamplify-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>);