안녕하세요! 테스트 질문입니다

강의에서는 인기글을 테스트할때 DataInitializer클래스에서 아래와 같은 코드를 사용했습니다.

    void createComment(Long articleId, long commentCount) {
        while(commentCount-- > 0) {
            commentServiceClient.post()
                    .uri("/v1/comments")
                    .body(new CommentRequest.Create(articleId, "content",null, 1L))
                    .retrieve();
        }
    }

이렇게 사용해봤더니 카프카에 전달이 되지 않더라구요

    void createComment(Long articleId, long commentCount) {
        while (commentCount-- > 0) {
            CommentRequest.Create request = new CommentRequest.Create(articleId, "content", null, 1L);

            try {
                // 요청 로깅 추가
                ObjectMapper objectMapper = new ObjectMapper();
                System.out.println("Request body: " + objectMapper.writeValueAsString(request));

                commentServiceClient.post()
                        .uri("/v1/comments")
                        .body(request)
                        .retrieve()
                        .toBodilessEntity();  // 응답 처리 추가
            } catch (Exception e) {
                System.out.println("Error: " + e.getMessage());
            }
        }
    }

이렇게 사용해야 인기글 서비스에서 아래처럼 로그가 찍히는걸 확인했습니다.
어디를 확인해야할까요 .. 몇시간째 해결을 못해서 질문드려요!!
[HotArticleEventConsumer.listen] received message = {"eventId":136009554918850560,"type":"COMMENT_CREATED"