[kafka] (Window환경) local환경 kafka CLI환경 설치 및 실행

 

1. 카프카를 실행하기 앞서 local환경에서 일단 다운로드를 받아준다 .. 아래의 사이트에서 버전에 맞게 다운 필요

아파치 카프카 (apache.org)

Apache Kafka

 

 

2. 파일을 다운받고 압축을 풀고난 이후 powershell or cmd 창을 열어서 kafka 디렉토리로 이동

    하여 서버시작 및 프로퍼티 실행을 진행한다.

 

  ( Zookiper 서버 실행 완료 )

 

 

bin\windows\zookeeper-server-start.bat
\config\zookeeper.properties

 

 

 

3. 서버 실행을 진행해준다.

 

 .\bin\windows\kafka-server-start.bat .\config\server.properties

 

 

 

4. 카프카서버및주키파 서버 생성하였으니 Topic 생성

 

(생성)
.\bin\windows\kafka-topics.bat --create --topic topic-example1 --bootstrap-server=localhost:9092
                                                (생성할토픽이름)                             ( 사용할 포트번호 )

 

 

5. Topic 생성한거 확인

 

 

(구독확인)
.\bin\windows\kafka-topics.bat --describe --topic topic-example1 --bootstrap-server=localhost:9092
                                 (확인)               (생성할토픽이름)                             ( 사용할 포트번호 )

 

 

 

 

6. 메시지 발행하기 (producer)

 

(토픽에 메시지발행)

.\bin\windows\kafka-console-producer.bat --topic topic-example1 --bootstrap-server=localhost:9092

 

7. 토픽에 메시지 발행한거 확인 (consumer)

 

 

.\bin\windows\kafka-console-consumer.bat --topic topic-example1 --from-beginning --bootstrap-server=localhost:9092
( ==> --from-beginning 첫번째 수신된 메시지 받겠다 이거 안스면 consumer 접속이후에 온메시지만 받음)

 

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

 .\bin\windows\kafka-server-start.bat .\config\server.properties


(생성)
.\bin\windows\kafka-topics.bat --create --topic topic-example1 --bootstrap-server=localhost:9092
                                                (생성할토픽이름)                             ( 사용할 포트번호 )

(구독확인)
.\bin\windows\kafka-topics.bat --describe --topic topic-example1 --bootstrap-server=localhost:9092
                                 (확인)               (생성할토픽이름)                             ( 사용할 포트번호 )


(토픽에 메시지발행)

.\bin\windows\kafka-console-producer.bat --topic topic-example1 --bootstrap-server=localhost:9092


.\bin\windows\kafka-console-consumer.bat --topic topic-example1 --from-beginning --bootstrap-server=localhost:9092
( ==> --from-beginning 첫번째 수신된 메시지 받겠다 이거 안스면 consumer 접속이후에 온메시지만 받음)

바로바로 topic 의 결과값이 반영된것을 알수 있다..