bin 디렉토리 하위 kafka-configs.sh 라는 이름의 쉘 스크립트가 있다.
kafka-configs.sh는 설정과 관련된 쉘 스크립트 커맨드 라인 툴이다.

1. 토픽 옵션 변경

alter 옵션과 add-config 옵션을 사용해 설정을 추가할 수 있다.

디폴트 옵션대로 생성된 test 토픽이 있다.

bin/kafka-configs.sh \
--bootstrap-server {브로커} \
--topic {토픽명} || broker {브로커 아이디} \
--alter \
--add-config {속성명}={속성값}

bin/kafka-configs.sh \
--bootstrap-server my-kafka:9092 \
--topic test \
--alter \
--add-config min.insync.replicas=2

예를 들어 min.insync.replicas 옵션을 토픽별로 설정할 수 있다.
min.insync.replicas 옵션은 프로듀서로 데이터를 보내고 컨슈머가 데이터를 읽을 때 워터마크 용도로 사용되기도 하고, 데이터를 얼마나 안전하게 보내야 하는지 설정할 때 사용한다.

Completed updating config for {대상}

옵션 설정에 성공한 경우 다음과 같은 로그를 확인할 수 있다.

describe 해보면 설정해준대로 min.insync.replicas 옵션이 추가된 것을 확인할 수 있다.

2. 브로커 설정값 조회

뿐만 아니라 kafka-configs.sh 명령어를 통해 broker, all, describe 옵션을 이용해 브로커에 설정된 여러 기본값들을 조회할 수 있다.

bin/kafka-configs.sh \
--bootstrap-server my-kafka:9092 \
--broker {브로커 번호}
--all \
--describe

bin/kafka-configs.sh \
--bootstrap-server my-kafka:9092 \
--broker 0 \
--all \
--describe

server.propertites 파일을 직접 열어보지 않더라도, 해당 파일에 설정된 기본값들을 조회하는 것이다.