SW개발/Kafka
3. Kafka broker의 주요 설정(properties)
이상한개발자
2020. 9. 16. 00:00
Kafka broker의 server.properties 파일에는 kafka broker에 대한 여러가지 옵션을 줄 수 있는데, 주요 옵션은 아래와 같습니다.
옵션 | 설명 |
broker.id | 브로커를 구분하기 위한 ID |
delete.topic.enable | 토픽 삭제 기능을 on/off(enable = 토픽 삭제 기능) |
default.replication.factor | 리플리케이션 팩터(Replication Factor) 옵션을 주지 않았을 경우의 기본값* |
min.insync.replicas | 최소 리플리케이션 팩터 |
auto.create.topics.enable | 존재하지 않는 토픽으로 퍼블리셔가 메시지를 보냈을 때 자동으로 토픽생성 |
offsets.topic.num.partitions | offsets 토픽의 파티션 수 |
offsets.topic.replication.factor | 토픽의 최종 압축형태, gzip, snappy, lz4 등의 표준 압축 포맷 지원. uncompressed는 압축을 하지 않음. producer는 producer가 보내는 압축 형태를 유지하라는 옵션 |
log.dirs | 로그 저장 위치 |
num.partitions | 파티션 수 옵션을 주지 않았을 경우의 기본값 |
log.retention.hours | 저장된 로그의 보관 주기* |
log.segment.bytes | 저장되는 로그 파일 하나의 크기 |
log.retention.check.interval.ms | 로그 보관주기 체크 시간 |
message.max.bytes | 카프카에서 허용하는 가장 큰 메세지 크기 |
zookeeper.connect | 주키퍼 접속정보* |
zookeeper.session.timeout.ms | 주키퍼 연결 최대 대기 시간 |
unclean.leader.election.enable | ISR 그룹에 포함되지 않은 마지막 리플리카를 리더로 인정. true(인정)/false(no 인정) |
log.flush.interval.ms | 메시지가 디스크로 플러시되기 전 메모리에 유지하는 시간 |
log.flush.interval.messages | 메시지가 디스크로 플러시되기 전 누적 메시지 수 |
이 외의 옵션 정보는 kafka.apache.org/documentation/#brokerconfigs 를 참고하세요.