명령어 정리

kafka-topics.sh

Topic 목록 조회

./kafka-topics.sh \
--list \
--bootstrap-server localhost:9092

Topic 상세 정보

./kafka-topics.sh \
--bootstrap-server localhost:9092 \
--describe \
--topic TOPIC_NAME

Topic 생성

./kafka-topics.sh \
--create \
--bootstrap-server localhost:9092 \
--replication-factor 1 \
--partitions 1 \
--topic TOPIC_NAME

Topic 제거

./kafka-topics.sh \
--bootstrap-server localhost:9092 \
--delete \
--topic TOPIC_NAME

kafka-console-producer.sh

특정 Topic과 연결된 producer 콘솔 열기

kafka-console-consumer.sh

특정 Topic을 Listen하는 consumer 콘솔 열기

kafka-consumer-groups.sh

컨슈머 그룹과 연관된 토픽, 파티션 조회

kafka-consumer-groups.sh --bootstrap-server <bootstrap-server> --list