src/test/java/com/sangdol/consumer/infrastructure/kafka/producer/DLTProducerTest.java

@@ -17,6 +17,7 @@ import org.springframework.test.context.bean.override.mockito.MockitoBean;
 
 import com.sangdol.consumer.domain.TestRecord;
 import com.sangdol.consumer.infrastructure.kafka.common.serialize.JsonObjectMapper;
+import com.sangdol.consumer.infrastructure.kafka.consumer.MultiWorkerConsumer;
 
 /**
  * Spring Retryable 동작 및 로그 출력 확인용 테스트
@@ -24,6 +25,9 @@ import com.sangdol.consumer.infrastructure.kafka.common.serialize.JsonObjectMapp
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
 class DLTProducerTest {
 
+	@MockitoBean
+	private MultiWorkerConsumer multiWorkerConsumer;
+
 	@MockitoBean
 	private KafkaProducer<String, String> kafkaProducer;