• 카테고리

    질문 & 답변
  • 세부 분야

    백엔드

  • 해결 여부

    해결됨

Kafka테스트 다른 테스트랑 같이 돌리면 실패하는데 이유를 모르겠습니다..

23.12.05 20:17 작성 23.12.05 20:19 수정 조회수 210

0

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

 

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

로그를 보면

잘 실행되고 문제도 없는데

 

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());
    }

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

답변 1

답변을 작성해보세요.

1

안녕하세요. 지식공유자 쥬쥬입니다!

 

아래 노션 확인 부탁드려요. 감사합니다!