diff --git a/src/test/java/com/sangdol/consumer/infrastructure/kafka/producer/DLTProducerTest.java b/src/test/java/com/sangdol/consumer/infrastructure/kafka/producer/DLTProducerTest.java index 2ffd6e6..94b4a04 100644 --- a/src/test/java/com/sangdol/consumer/infrastructure/kafka/producer/DLTProducerTest.java +++ b/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 kafkaProducer;