작업 넣고 가져오고 워커로 보낸 후 커밋 날리라는데
이러면 워커에서 문제 생기면 작업 유실되는거 아님?
그렇다고 대기열 큐로 쓰기엔 긴 작업은 그동안 기다려야하고
워커에게서 ack를 받아
아니네. 윗 댓은 내가 kafka 잘 몰라서 한 소리니 무시해 ㅇㅇ 나도 이번에 카프카 문서 처음 읽어봤는데, 커밋을 못 받으면 계속 재시도하고 재시도 여러번 실패하면 dead로 분류하면 되네.
작업유실관점에서만 보면 워커서버에서 완료한뒤 ACK받으면 되는거 맞지않음? 물론 완료한 타이밍에 워커서버 뒤지면 다시 실행하겠지만 작업자체가 날라가진않겠지
@프갤러1(116.45) 나도 그렇게 생각했는데 kafka가 커밋을 못 받으면 ack못 받은 거랑 똑같으니까 굳이 커스텀 ack쓰기보단 kafka 커밋 쓰는 게 맞지 않나? 싶어서
워커에게서 ack를 받아
아니네. 윗 댓은 내가 kafka 잘 몰라서 한 소리니 무시해 ㅇㅇ 나도 이번에 카프카 문서 처음 읽어봤는데, 커밋을 못 받으면 계속 재시도하고 재시도 여러번 실패하면 dead로 분류하면 되네.
작업유실관점에서만 보면 워커서버에서 완료한뒤 ACK받으면 되는거 맞지않음? 물론 완료한 타이밍에 워커서버 뒤지면 다시 실행하겠지만 작업자체가 날라가진않겠지
@프갤러1(116.45) 나도 그렇게 생각했는데 kafka가 커밋을 못 받으면 ack못 받은 거랑 똑같으니까 굳이 커스텀 ack쓰기보단 kafka 커밋 쓰는 게 맞지 않나? 싶어서