본문 바로가기

Programming/Tip&Informaion

[실수노트] kafka consumer 무한 루프

kafka로 데이터를 전송했었는데, 데이터가 잘못된 경우가 발생했다.
받는 쪽에서는 무한 retry하도록 설정되어 있었다. 그래서 처음에는 consumer를 죽이고, 메시지만 미리 받아놓고 consumer를 재실행하자고 했는데, 웹이랑 하나의 어플리케이션으로 되어있어서 부담스러워 했다.
그래서 생각한 게 일단 retension을 아주 짧은 시간으로 바꿔서 메시지를 없애는 방식을 이용했다.
메시지가 전부 사라진 다음에 결국 서버재배포를 하긴 했지만.