kafka 실행 / topic 생성 / topic 조회 (2.2 버전 이상 / 미만 포함)

회사에서설치돼 있는 kafka 버전이 오래된 버전이라 topic 생성 및 조회에 살짝의 삽질을 하여서 .. 2.2 버전 기준으로 topic 생성 및 조회 명령어 정리하였습니다.

1. kafka 실행 (단독 실행 기준)

#주키퍼 실행
$./bin/zookeeper-server-start.sh config/zookeeper.properties
#카프카 실행
$./bin/kafka-server-start.sh config/server.properties

2. topic 생성

#2.2버전 미만
$ bin/kafka-topics.sh --create --topic topic_name --replication-factor 1 \
   --partitions 1  --zookeeper localhost:2181
#2.2버전 이상
$ bin/kafka-topics.sh --create --topic topic_name --replication-factor 1 \
   --partitions 1  --bootstrap-server localhost:9092

3. topic 조회

#2.2 버전 미만
$ bin/kafka-topics.sh --list --zookeeper localhost:2181
topic_name

#2.2 버전 이상
$ bin/kafka-topics.sh --bootstrap-server=localhost:9092 --list
topic_name

4. 출처
https://www.baeldung.com/ops/kafka-list-topics