kafka 서버간 통신

Question

현재 카프카로 서버간의 restAPI 통신을 구현하려고 하는데요예를들어 게시판 생성 요청을 예로 들어보겠습니다.게시판에는 멤버정보가 들어가는데요게시판 생성요청 정보에는게시판 제목게시판 내용멤버 id가 있구요게시판 생성요청시에 작성자id 를 가지고 멤버 서버로 멤버 정보를 요청하는 방식을 해보려고 합니다. 카프카를 사용할때 1 . 게시판서버 postCreate메서드에서 프로듀서로 작성자id 를 특정 토픽에 보내고 2 . member서버에서 컨슈머 리스너를 통해 해당 토픽에 요청정보가 들어오면 3 . 요청을 처리(member의 존재 유무)하고 다시 게시판서버로 객체(member객체)를 반환 해주려고 하는데 이것을 다시 프로듀서로 작성하고 4 . 게시판서버에서 리스너로 응답받은 member객체를 postCreate메서드에서 post객체를 완성시키려고 했습니다.찾아보니 컨슈머 리스너는 void 이어야 한다고 하더라구요. 그렇게 되면 요청과 응답을 받는것을 어떻게 한 메서드 안에서 처리 해야 하나요? 찾아본 방법으로는 kafka rest proxy 라는것도 찾아봤는데 현업에서 사용하는 방법이 따로 있는지 궁금합니다.requestDto로 post서버에서는 post객체를 만들어 따로 저장하고 memberId는 멤버서버로 보내서 멤버가 있는지 확인하고 트랜젝션 종료 한다. 멤버가 없으면 트랜젝션 롤백 시켜서 post객체를 만든것을 롤백시킨다 ?혼자 서버 분리시키고 두 서버간 비동기 통신을 구현해보려고 하는데 막히네요 ㅜㅜㅜ긴 글 읽어주셔서 감사합니다

토끼왕 · Answer

Q. 그렇게 되면 요청과 응답을 받는것을 어떻게 한 메서드 안에서 처리 해야 하나요?A. 프로미스 패턴을 이용하시면 되겠습니다

kafka 서버간 통신

1개의 답변

기술 목록