일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | |||
5 | 6 | 7 | 8 | 9 | 10 | 11 |
12 | 13 | 14 | 15 | 16 | 17 | 18 |
19 | 20 | 21 | 22 | 23 | 24 | 25 |
26 | 27 | 28 | 29 | 30 | 31 |
- Reactive
- kafka
- java
- NoClassDefFoundError
- restdocs
- Vmagent
- ProjectLoom
- VictoriaMetrics
- webflux
- 비동기
- Brooklin
- broker
- OFFSET
- swagger
- ExecutableJar
- springboot
- JDK
- Mirror
- JVM
- Zookeeper
- OpenJDK
- tsdb
- consumer
- spring
- API문서
- Rebalance
- Vmalert
- Reassign
- raft
- Today
- Total
목록 kafka (10)
거북이 developer
Kafka 에서 rebalance가 의미하는 것은 Group resource 재할당 Membership 변화 자세한 설명은 [Consumer 파티션 리밸런싱] 참조 1. Static Membership이란? Dynamic Membership과는 다른, multi group내에서 영속적인 멤버를 이야기한다. 같은 구독을 재사용하도록 하고 구 member들이 코디네이터로 부터 인식할 수 있도록 한다가 목표이다. 새로운 consumer는 "group.instance.id" 설정을 사용하여 consumer instance에서 unique를 보장하도록 설정한다. 다시 시작하는 동안 코디네이터에 assign된 memberID가 손실되지만, 코디네이터는 이 멤버를 join Reqeust에서 제공된 그룹 instanc..
파티션 리밸런싱이 발생하는 케이스 KafkaConsumer.close 가 호출되어 코디네이터에게 consumer 가 종료 되는 것을 알렸을 때. heartbeat.interval.ms 간격으로 호출되는 하트비트가 session.timeout.ms 동안 오지 않았을 경우 코디네이터에서 해당 컨슈머를 컨슈머그룹에서 제외하고 파티션 리밸런싱 발생. max.poll.interval.ms 동안 poll 요청이 없을 경우 코디네이터에서 해당 컨슈머를 컨슈머그룹에서 제외하고 파티션 리밸런싱 발생. Consumer 가 신규로 추가되어 파티션 분배가 필요한 상황일 경우. 파티션 수를 증가 시켰을 때 코디네이터란❓ 모든 브로커는 특정 컨슈머 그룹의 코디네이터 역할을 합니다. 코디네이터는 컨슈머 그룹의 멤버 변화가 생겼을 ..