● 주키퍼와 카프카 실행
● 테스트
- 주기퍼와 카프카가 정상적으로 포트가 오픈 되어 있는지 확인
|
### 주키퍼 포트확인 netstat –an | grep 2181 ### 카프카 포트확인 Netstat -an | grep 9092 |
- 포트가 정상적으로 LISTEN 상태이면 주기퍼 지노드를 이용해서 카프카 정보를 확인
|
./zookeeper/bin/zkCli.sh |
- 주키퍼로 접속한 다음 ls / 를 치면 기본 노드와 추가한 노드 확인
|
[incon-kafka, zookeeper] |
- 카프카 클러스터 노드들이 잘 연결되었는지 확인
|
ls /incon-kafka/brokers/ids ##출력결과 [1, 2, 3] |
- 잘되었으면 quit 로 종료
- 토픽 생성
|
kafka-topics.sh --zookeeper kafka1:2181,kafka2:2181,kafka3:2181/incon-kafka --replication-factor 3 --partitions 1 --topic new-topic --create |
- 토픽 LIST 확인(둘 중 하나실행)
|
bin/kafka-topics.sh --list --zookeeper localhost:2181 bin/kafka-topics.sh --list --bootstrap-server localhost:9092 |
- 토픽 환경설정 확인
|
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test |
- 프로듀서
|
kafka-console-producer.sh --broker-list kafka1:9092,kafka2:9092,kafka3:9092 --topic new-topic |
- 엔터를 치고 기다려면 > 프롬포트가 깜빡이면 메시지 입력
|
## 입력 > Hello Kafka1 > Hello Kafka2 |
- 컨슈머
|
kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic new-topic --from-beginning |
- 확인
|
## 출력 > Hello Kafka1 > Hello Kafka2 |
* PATH 설정
-/home 디렉토리의 vi .bash_profile 에 추가
|
:/opt/kafka/bin:/opt/zookeeper/bin |
이후
주키퍼 실행 : zkServer.sh start
카프카 실행 : kafka-start.sh
'* KAFKA > KAFKA 설치' 카테고리의 다른 글
| KAFKA Manager 설치 (0) | 2019.07.22 |
|---|---|
| KAFKA 설치 (0) | 2019.07.22 |
| KAFKA(카프카) & ZOOKEEPER(주키퍼) (0) | 2019.07.22 |