Kafka - CLI

토픽 생성 / 제거 / 조회

# topic 생성
kafka-topics.sh --bootstrap-server localhost:9092 --create -topic #{topic_name}
# 파티션지정 생성
kafka-topics.sh --bootstrap-server localhost:9092 --create -topic #{topic_name} 
--partitions ${partition_number}
# replication-factor 지정
kafka-topics.sh --bootstrap-server localhost:9092 --create -topic #{topic_name} 
--partitions ${partition_number} --replication-factor #{replication_number}


# topic 제거
kafka-topics.sh --bootstrap-server localhost:9092 --topic #{topic_name} --delete


# topic list 체크
kafka-topics.sh --bootstrap-server localhost:9092 --list
# topic 정보
kafka-topics.sh --bootstrap-server localhost:9092 #{topic_name} --describe