728x90
#토픽 생성
kafka-topics.sh --create --bootstrap-server <IP:port> --replication-factor 1 --partitions 30 --topic myTopic
#토픽 리스트 조회
kafka-topics.sh --list --bootstrap-server <IP:port>
#토픽 정보 상세 조회
kafka-topics.sh --describe --topic myTopic --bootstrap-server <IP:port>
#토픽 프로듀서 ( 생성 )
kafka-console-producer.sh --topic <토픽이름> --bootstrap-server <브로커주소>
#토픽 컨슈머 ( 조회 )
kafka-console-consumer.sh --bootstrap-server <IP:port> --topic myTopic
kafka-console-consumer.sh --bootstrap-server <IP:port> --topic myTopic --from-beginning
#토픽 삭제
kafka-topics.sh --delete --bootstrap-server <IP:port> --topic myTopic
커맨드가 없다고 뜨면 명령어 앞 .sh 를 지우고 실행 시킨다
728x90
'개-발 > Infra' 카테고리의 다른 글
[ubuntu] 우분투 내 맘대로 설정들 (0) | 2024.10.17 |
---|---|
[aws] S3 bucket 버킷 복제 하기 for macOS (0) | 2024.10.17 |
[오류노트] 윈도우 WSL 도커 컨테이너 Kafka 외부 접속 (0) | 2024.09.26 |
[NAS] 시놀로지 Nas 도메인 설정 (0) | 2024.08.20 |
[Docker] 이미 생성된 컨테이너의 포트 바꾸기 (0) | 2024.08.20 |