Kafka Windows 설치 및 테스트

1. 다운로드

다운받고 파일을 압축을 풀어준다.

Kafka 다운로드

압축을 풀고 cmd를 이용해 (kafka 압축 해제 경로)\bin\windows로 이동한다.

Broker는 Kafka의 서버를 의미하며 동일 노드 내에서 여러개의 Broker를 띄울 수 있다. 여러개의 Broker가 띄워져 있으면 이 분산 Message Queue를 Zookeeper가 관리한다. Kafka 서버를 띄우기 전에 Zookeeper를 반드시 띄워야 한다.

2. Zookeeper 실행

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

3. Kafka 서버 실행

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

4. Zookeeper 및 Kafka 실행 확인

netstat -a

• 2181 포트: Zookeeper

• 9002 포트: Kafka

5. Kafka 테스트

1) topic 생성 (broker)

kafka-topics.bat --create --bootstrap-server localhost:9092 --topic topic-test

• 생성한 topic 조회

kafka-topics.bat --list --bootstrap-server localhost:9092

2) topic에 message 보내기 (producer)

kafka-console-producer.bat --broker-list localhost:9092 --topic topic-test

3) topic에 message 가져오기 (consumer)

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic-test --from-beginning

[출처 및 참고]

• https://oingdaddy.tistory.com/274