일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
- Spring Boot
- elasticsearch
- jsp
- Git
- Gradle
- laravel
- jenkins
- Design Patterns
- 요리
- java
- AWS
- php
- Spring
- ubuntu
- Web Server
- MySQL
- ReactJS
- javascript
- it
- devops
- db
- tool
- 맛집
- springboot
- redis
- JPA
- IntelliJ
- docker
- Oracle
- linux
- Today
- Total
목록2020/07/31 (2)
아무거나
컨슈머 주요 옵션 bootstrap.servers: 카프카 클러스터에 연결을 하기 위한 호스트와 포트정보를 입력 ex) 127.0.0.1:9092,127.0.0.2:9092 ... fetch.min.bytes: 한번에 가져올 수 있는 최소 데이터 사이즈 만약, 지정한 사이즈보다 작은 경우, 요청에 대해 응답하지 않고 데이터가 누적될 때까지 기다린다. group.id: 컨슈머가 속한 컨슈머 그룹을 식별하는 식별자. (중요) enable.auto.commit: 백그라운드로 주기적으로 오프셋을 커밋한다. auto.offset.reset: 카프카에서 초기 오프셋이 없거나 현재 오프셋이 더 이상 존재하지 않은 경우에 다음 옵션으로 리셋한다. auto.offset.reset=earliest: 가장 초기의 오프셋값으..
프로듀서 주요 옵션 bootstrap.servers: 카프카 클러스터에 연결을 하기 위한 호스트와 포트정보를 입력 ex) 127.0.0.1:9092,127.0.0.2:9092 ... acks: 프로듀서가 카프카 토픽의 리더에게 메세지를 보낸 후 요청을 완료하기 전 ack(승인)의 수 해당 옵션의 수가 작으면 성능이 좋지만 메세지 손실 가능성이 있고, 반대로 수가 크면 성능이 좋지 않지만 메세지 손실 가능성도 줄어들거나 없어진다. acks=0: 프로듀서는 서버로부터 어떠한 ack도 기다리지 않습니다. 그러므로 메세지 손실 가능성이 있으며 결과를 알지 못하므로 재요청 설정도 적용되지 않는다. acks=1: 리더는 데이터를 기록하지만, 모든 팔로워는 확인하지 않는다. 즉, 일부 데이터의 손실이 발생할 수 있다..