[Kafka] 카프카 명령어 모음

[Kafka] 카프카 명령어 모음

 

 

명령어 실행 위치: /usr/local/kafka/bin

 

주로 사용하는 명령어

kafka-topics.sh : 토픽을 생성하거나 토픽의 설정 등을 변경할 때 사용한다. kafka-console-producer.sh : 토픽으로 메시지를 전송할 때 사용한다. kafka-console-consumer.sh : 토픽으로 메시지를 가져올 때 사용한다. kafka-reassign-partitions.sh : 토픽의 파티션과 위치를 변경할 때 사용한다. kafka-dump-log.sh : 파티션에 저장된 로그 파일의 내용을 확인할 때 사용한다.

 

 

 

• 토픽 생성

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

"topic명"으로 토픽 생성

파티션 수: 1

원본을 포함한 리플리케이션 수: 1