Kafka Topic이란?
데이터를 최종적으로 저장하는 곳인데, 데이터를 구분하기 위한 저장소
Kafka CLI : kafka-topics.sh
- 카프카 3부터 이루어지는 옵션
# 해당 옵션은 사용하지 않는다. 곧 사리지기 때문.
--zookeeper
# 이 옵션으로 사용
--bootstrap-server
Kafka CLI : kafka-topics.sh
목차
- 카프카 토픽 생성
- 카프카 토픽으로 만든 클러스터.
- 토픽 리스트 확인
- 토픽 상세 정보 조회
- 토픽의 파티션 개수 조절
- 카프카 토픽 삭제
카프카 토픽 생성
# 토픽 생성 명령어
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --create
# 완료 메세지
Created topic first_topic.
# 토픽 파티션 설정
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --create --partitions [파티션 개수]카프카 레플리카 만들기
- 복제 계수는 갖고 있는 브로커 개수보다 크면 안된다.
- 파티션을 2회 복제할 수 없다 : 브로커가 1개만 등록되어 있어서 대상 복제 인자 2에 도달할 수 없다고 나온다.
# 브로커 보다 많은 복제 개수를 했을때
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --create --partitions 3 --replication-factor 2
# 브로커 보다 적거나 같은 복제 개수를 했을때
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --create --partitions 3 --replication-factor 1
# 정상 메세지 출력
Created topic third_topic.카프카 조회 및 삭제
# 토픽 리스트 확인
kafka-topics.sh --bootstrap-server localhost:9092 --list
# 토픽 상세 보기
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --describe
# 토픽 삭제
kafka-topics.sh --bootstrap-server localhost:9092 --topic [토픽명] --delete