거북이 developer

파티션 리밸런싱이 발생하는 케이스 KafkaConsumer.close 가 호출되어 코디네이터에게 consumer 가 종료 되는 것을 알렸을 때. heartbeat.interval.ms 간격으로 호출되는 하트비트가 session.timeout.ms 동안 오지 않았을 경우 코디네이터에서 해당 컨슈머를 컨슈머그룹에서 제외하고 파티션 리밸런싱 발생. max.poll.interval.ms 동안 poll 요청이 없을 경우 코디네이터에서 해당 컨슈머를 컨슈머그룹에서 제외하고 파티션 리밸런싱 발생. Consumer 가 신규로 추가되어 파티션 분배가 필요한 상황일 경우. 파티션 수를 증가 시켰을 때 코디네이터란❓ 모든 브로커는 특정 컨슈머 그룹의 코디네이터 역할을 합니다. 코디네이터는 컨슈머 그룹의 멤버 변화가 생겼을 ..