Feat #124 채팅 카프카 이전

[hyxklee]

📌 관련 이슈

관련 이슈 번호 #74
Close #74

🚀 작업 내용

• 이전 redis로 메시지 발행을 하던 것을 카프카로 이전했습니다.

• 이전한 이유는 무중단 배포가 돌아갈 때 발행된 메시지의 유실을 막기 위해 이전하였습니다.

• 카프카에 chat-group을 추가하였고, 채팅을 위한 topic을 추가했습니다.

• ChatMessage만 다루는 Producer, Consumer 설정을 추가했습니다. ACK는 All로 설정해 메시지 유실을 방지했고, 재시도 횟수는 3회로 설정했습니다.

• KafkaChatSubscriber에서 메시지를 받을 시 ack를 읽음 처리해 메시지 중복 처리를 막았습니다.

• jmeter를 이용한 부하테스트시 무중단 테스트까지는 진행하지 못했지만, 서버가 꺼진 상태에서 카프카에 메시지가 전송된 경우 서버가 다시 켜졌을 때 처리되지 않은 메시지부터 Consumer에게 정상적으로 발행되는 것을 테스트 완료했습니다

📸 스크린샷

• 자체 채팅 테스트 진행했습니다

📢 리뷰 요구사항