kafka 실행및 테스트, 점검법

참고원문 : 둘다 괜찮다.  두번째 링크의 맨 하단의 운영담당자의 글모음도 나중에 읽어보자.

https://judo0179.tistory.com/95

https://www.tigiminsight.com/kafka_setup_examples

 

 

설치는 다른 문서를 보고...

 

기동 여부

$ sudo systemctl status zookeeper

$ sudo systemctl status kafka

 

Active: inactive (dead)

 

상태가  active/inactive 인지 확인

 

실행은 

$ sudo systemctl start zookeeper

$ sudo systemctl start kafka

 

수동으로 토픽 생성하기(토픽명 testTopic)

$ cd /opt/kafka

$ sudo bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testTopic Created topic "testTopic".

 

생성된 토픽 리스트 조회

$ sudo bin/kafka-topics.sh --list --zookeeper localhost:2181

 

토픽에 메시지 생성

$ sudo bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic 

> Hello

> Kafka

 

컨슈머를 통한 메시지 수신 기능 테스트

$ sudo bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning

> Hello

> Kafka

 

카프카 원격 접속 허용

$ cd /opt/kafka/config $ sudo vi server.properties

# listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://<HOST IP>:9092