본문 바로가기

카테고리 없음

카프카 간단 실행

1. 자바 1.8 이상 다운로드 및 설치

2. 아래 사이트에서 버전에 맞는 카프카 다운로드

 - https://kafka.apache.org/downloads

 

Apache Kafka

Apache Kafka: A Distributed Streaming Platform.

kafka.apache.org

3. 카프카 압축 해제

4. 아래 명령어로 주키퍼 실행

 - bin/zookiper-server-start.sh /config/zookiper.properties
5. 새로운 터미널 띄움

6. vi config/server.properties

   - advertiesd.listners 를 주석 해제및 localhost:9092로 변경 

   - advertiesd.listners는 프로듀서와 컨슈머에게 브로커  접속 정보를 알려줌

7. 카프카 서버 실행

 - bin/kafka-server-start.sh config/server.properties

7. 새로운 터미널을 열어서 토픽을 생성

 - bin/kafka-topics.sh --create --topic topic-ex --bootstrap-server localhost:9092

8. 토픽 정보를 확인

 - bin/kafka-topics.sh --describe --topic topic-ex --bootstrap-server localhost:9092

9.새로운 터미널을 열고 프로듀서 실행

 - bin/kafka-console-producer.sh --topic topic-ex --bootstrap-server localhost:9092

10. 새로운 터미널을 열고 컨슈머 실행

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

11. 프로듀서에서 메세지를 입력후 엔터치면 컨슈머 창에 노출됨