Kafka(5) - Kafka Docker 사용법

Docker 컨테이너로 kafka 를 설치하였다. 

Kafka(4) - Kafka Docker 설치

 

 

docker compose 실행 후, 도커 컨테이너 확인 

$ docker-compose up -d
$ sudo docker ps

kafka와 zookeepr 실행 중

Kafka 컨테이너 실행 

$ sudo docker exec -it (docker NAMES) bash

kafka 정상 실행

Topic 생성

$ kafka-topics.sh --create --bootstrap-server kafka:9092 --replication-factor 1 --partitions 1 --topic (topicname)

카프카 토픽에 전송된 메시지는 가용성을 위해 여러 브로커에 복제되어 저장

• Replica : 복제된 메시지 
• Replication Factor (RF) : 몇개의 Replica로 복제할 것인지

--replication-factor 로 통해 수동 설정 

--partitions 으로 파티션 갯수 수동 설정 

 

 

Topic 목록 조회 및 삭제

$ kafka-topics.sh --list --bootstrap-server kafka:9092
$ kafka-topics.sh --delete --bootstrap-server kafka:9092 --topic (topicname)

 

Producer 로 데이터 삽입 , Consumer 데이터 조회 

$ kafka-console-producer.sh --bootstrap-server kafka:9092 --topic (topicname)
$ kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic (topicname) --from-beginning

왼쪽 Producer, 오른쪽 Consumer