1. 카프카를 실행하기 앞서 local환경에서 일단 다운로드를 받아준다 .. 아래의 사이트에서 버전에 맞게 다운 필요
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 의 결과값이 반영된것을 알수 있다..
'기존 > 🖲️kafka' 카테고리의 다른 글
[kafka] kafka 인증추가 SASL/SCRAM 방식 및 프로메테우스 및그라파나 (0) | 2023.12.24 |
---|---|
[kafka] kafka 파티션 추가 및 생성 및 재배치 할당 (0) | 2023.12.24 |
[kafka] Aws MSK 서비스 실행 및 확인 (0) | 2023.12.24 |
[kafka] kafka cluster 코드 (0) | 2023.12.24 |
[kafka](Window환경) kafka Cluster 설치 및 실행 (0) | 2023.12.24 |