인프런 커뮤니티 질문&답변

예시 코드대로 카프카 테스트를 실행하면 잘 성공합니다.

그런데 다른 통합테스트들과 같이 실행시키면 실패합니다.

로그를 보면

잘 실행되고 문제도 없는데

process메서드를 잘 실행 했음에도 불구하고 수행되지 않았다고 나오는거 같습니다.

    @SlowTest
    public void kafkaSendAndConsumeTest() {
        String topic = "test-topic";
        String expectValue = "expect-value";

        kafkaProducerService.send(topic, expectValue);


        var stringCaptor = ArgumentCaptor.forClass(String.class);
        System.out.println("-----------mock-----------start");
        Mockito.verify(kafkaConsumerService, Mockito.timeout(5000).times(1))
                .process(stringCaptor.capture());
        System.out.println("-----------mock-----------finish");

        Assertions.assertEquals(expectValue, stringCaptor.getValue());
    }

혹시 관련 문제에 대해 아실까요? ㅠㅠ