[Kafka] 4. 카프카 컨슈머
목차 1. 컨슈머 Client 2. Poll 3. Heartbeat Thread 4. 리밸런싱 5. 오프셋 커밋 6. 특정 파티션만 할당 7. 컨슈머의 안전한 종료 8. 멀티 스레드 컨슈머 9. 컨슈머 랙 10. 스프링 카프카 컨슈머 1. 컨슈머 Client 카프카 컨슈머는 하나의 컨슈머 그룹에 속해 실행되며 카프카 브로커의 파티션은 컨슈머 그룹내 하나 이상의 컨슈머에 할당된다. 기본 컨슈머 Client API 처리 로직 // 1. Consumer 환경 설정(Properties 객체를 이용) String topicName = "simple-topic"; Properties props = new Properties(); props.setProperty(ConsumerConfig.BOOTSTRAP_SERVE..
Kafka
2023. 2. 2. 11:04
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크
TAG
- ATDD
- 트랜잭셔널 아웃박스 패턴
- java8
- 육각형 아키텍처
- HTTP 헤더
- 계층형 아키텍처
- Ubiquitous Language
- 학습 테스트
- 클린코드
- Stream
- MySQL
- http
- Spring
- spring rest docs
- mockito
- clean code
- 폴링 발행기 패턴
- 마이크로서비스 패턴
- Spring Boot
- Spring Data JPA
- 이벤트 스토밍
- 스프링 예외 추상화
- TDD
- H2
- kafka
- 스프링 카프카 컨슈머
- Git
- JPA
- 도메인 모델링
- named query
| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 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 |
글 보관함