Kafka Rebalance 성능 개선기 (consumer 프로토콜)

항목	신규 구현의 처리
인스턴스 수	`consumerInstanceCount`를 컨테이너의 `concurrency`에 연결했다.
커밋 시점	`AckMode.BATCH`로 poll 배치 처리 후 커밋하는 방식을 유지했다.
실행 스레드	`VirtualThreadTaskExecutor`를 사용했다.
프로토콜 파싱	알 수 없는 값은 모듈에서 `CLASSIC`으로 해석하도록 했다.
정적 멤버십	기본값을 `false`로 바꾸고 필요한 컨슈머에서만 활성화하도록 했다.
시작	컨슈머 시작 제어 로직에서 그룹 ID 단위로 시작 요청을 묶고, 실패하면 지수 백오프로 재시도하도록 했다.
종료	preStop drain에서 pause, 진행 중인 처리 소진, 컨슈머 닫기를 순서대로 수행하도록 했다.

조건	동작과 이유
적재량이 high 이상이다.	확인할 때마다 pause를 요청한다. 이미 플래그가 켜져 있어도 같은 요청을 반복한다.
적재량이 low와 high 사이에 있다.	기존 상태를 유지한다. 한 경계에서 pause와 resume이 반복되는 것을 피한다.
pause 요청에 실패했다.	플래그를 바꾸지 않고 다음 확인 때 다시 시도한다.
백프레셔로 pause한 상태에서 low 이하가 됐다.	drain 중이 아닐 때만 resume을 요청한다.
drain이 진행 중이다.	백프레셔 조건이 풀려도 resume하지 않는다.

Kafka 리밸런스 프로토콜 비교: Classic과 KIP-848 Consumer (1)	2026.08.31
Kafka 파티션 증가 없이 처리량 늘리기 (feat. Parallel Consumer, Share Group) (0)	2026.08.29

들어가기 전