반응형
Notice
Recent Posts
Recent Comments
Link
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
Tags
- nestjs
- JPA 공부
- nestjs공부
- 스프링공부
- Kafka
- 자료구조공부
- JPA공부
- 기술공부
- 코테공부
- Axon framework
- 기술면접공부
- 프로그래머스
- querydsl
- 스프링 공부
- nestjs스터디
- 스프링부트
- DDD
- 알고리즘공부
- K8S
- 스프링부트공부
- 카프카
- JPA예제
- 플러터 공부
- Flutter
- JPA
- 코테준비
- JPA스터디
- 플러터 개발
- 스프링
- 자바공부
Archives
- Today
- Total
목록카프카 세그먼트 (1)
DevBoi
[Kafka] 브로커의 역할
데이터의 저장 카프카를 실행할때 Config/server.properties 의 log.dir 옵션에 정의한 디렉토리에 데이터를 저장한다. 토픽 이름과 파티션 번호의 조합으로 하위 디렉토리를 생성하여 데이터를 저장한다. -hello.kafaka 토픽의 0번 파티션에 존재하는 데이터를 확인 할 수 있다. log에는 메시지와 메타데이터를 저장한다. index는 메시지의 오프셋을 인덱싱한 정보를 담은 파일이다. timeindex파일에는 메시지에 포함된 타임스탬프 값을 기준으로 인덱싱한 정보가 담겨있다. 만약에 3개짜리 파티션을 만들게 되면, 해당 토픽이 3개로 저장된다.(나눠서가 아닌 복제형태로) 프로듀서는 메시지 (레코드)를 보내게 되는데 이 레코드 안에는 타임스탬프,메시지키,메시지 값 들의 정보가 들어가있..
Develop/[Kafka]
2023. 7. 20. 00:38