[Kafka] 기본 명령어

아래 명령어들은 구버전 명령어들임.

새로운 버전의 명령어들은 공식 문서(kafka.apache.org/documentation/) 혹은 quick start 에서

아래 구버전 명령어들의 키워드로 검색하여 찾아보자.

 

 

예를 들어 topic create 구버전 명령어가 

kafka-topics.sh --zookeeper localhost:2181/localhost --topic tp1 --create

였다면 --create 를 키워드로 공식문서를 검색하여

kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

이런 식으로 찾으면 되겠다.

대신 영어를 좀 알아야겠지.

 

 

ㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡㅡ

 

 

아래 bold 처리 한 부분들은 각자 환경에 따라 다름.

 

 

topic 및 partition 생성 방법

./kafka/bin/kafka-topics.sh --zookeeper localhost:2181/localhost --replication-factor 1 --partitions 1 --topic tp1 --create

 

topic 에 데이터 넣는 방법

./kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic tp1

이후 나오는 프롬프트에 데이터를 넣으면 된다.

 

topic 에 README.md 파일을 넣는 방법

./kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic tp1 < README.md

 

topic 내의 메세지 삭제 방법

삭제 주기를 1초 등으로 줄여서 삭제하고, 다시 늘리면 됨.

./kafka/bin/kafka-topics.sh --zookeeper localhost:2181/localhost --alter --topic tp1 --config retention.ms=1000

 

혹은 토픽 자체를 삭제한 후 다시 생성

server.properties 에 delete.topic.enable=true 추가

./kafka/bin/kafka-topics.sh --zookeeper localhost:2181/localhost --delete --topic tp1

 

 

topic 에 대한 정보 보기(topic leader follower check)

./kafka/bin/kafka-topics.sh --describe --zookeeper localhost:2181/localhost --topic tp1

 

그 외 카프카 명령어 모음

data-newbie.tistory.com/241