kafka-topics.sh 파라미터 설명

출처: https://kafka.apache.org/0102/documentation.html

kafka-topics.sh의 도움말 해석입니다. (0.10.2 기준)

의역이나 오역이 있을 수 있습니다.

--alter

: 토픽의 파티션 수나 복제 개수를 변경

--config <String: name=value>

: 이미 만들어져 있는 토픽의 설정을 오버라이드

--create

: 새로운 토픽 생성

--delete

: 토픽 삭제

--delete-config <String: name>

: 삭제 될 토픽의 설정 오버라이드

--describe

: 토픽의 상세 정보 출력

--force

: 강제로 명령 실행

--help

: 도움말 출력

--if-exists

: 토픽을 지우거나 수정할 때 토픽이 존재하는지 먼저 검사

--if-not-exists

: 토픽을 생성할 때 토픽이 존재하지 않을때만 실행

--list

: 사용가능한 모든 토픽의 목록을 출력

--partitions <Integer: # of partitions>

: 생성되거나 수정될 토픽의 파티션 개수 지정 (기존 보다 커질 경우 파티션 로직이나 메시지의 순서에 영향을 줄 수 있음)

--replication-factor <Integer: replication factor>

: 토픽이 생성될 때 복제할 개수

--topic <String: topic>

: 토픽을 생성할때, 수정할때 지정할 토픽 이름

--zookeeper <String: urls>

: (필수) host:port 형태의 주키퍼 연결 정보, fail-over를 위한 여러개의 urls 가능

예시)

test라는 이름으로 10개의 파티션과 3개의 복제본을 가진 토픽을 생성할 때

kakfa-topics.sh --zookeeper 192.168.0.10:2181,192.168.0.11:2181 --topic test --partitions 10 --replication-factor 3 --create

test라는 이름이 없을 때만 10개의 파티션과 3개의 복제본을 가진 토픽을 생성할 때

kakfa-topics.sh --zookeeper 192.168.0.10:2181,192.168.0.11:2181 --topic test --partitions 10 --replication-factor 3 --create --if-not-exists

test라는 이름의 토픽이 존재하면 해당 토픽 삭제

kakfa-topics.sh --zookeeper 192.168.0.10:2181,192.168.0.11:2181 --topic test --if-exists --delete

test라는 이름의 토픽이 존재하면 해당 토픽 강제 삭제

kakfa-topics.sh --zookeeper 192.168.0.10:2181,192.168.0.11:2181 --topic test --if-exists --delete --force