반응형
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 공부
- 코테공부
- 자료구조공부
- JPA스터디
- DDD
- nestjs
- Flutter
- 기술공부
- 플러터 공부
- 프로그래머스
- Axon framework
- 스프링공부
- 자바공부
- 알고리즘공부
- 스프링부트공부
- nestjs공부
- 기술면접공부
- 스프링 공부
- 플러터 개발
- Kafka
- JPA
- 스프링부트
- JPA예제
- JPA공부
- querydsl
- K8S
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