카프카 설치 방법 - Windows

* Kafka 2.11-0.10.2.2 버전 기준

 

[ 카프카 다운로드 ]

 

1. 홈페이지에서 Kafka 다운로드

kafka.apache.org/downloads

Apache Kafka

2. Kafka 폴더에 다운로드 파일 압축 해제 [ C:\kafka\kafka_2.11-0.10.2.2 ]

 

3. Kafka Windows 버전 실행 파일은 bin\windows 폴더에 위치

4. Kafka와 Zookeeper 설정 파일은 config 폴더에 위치

 

[ 카프카 실행 ]

 

5. cmd 창에서  zookeeper 실행 [ C:\kafka\kafka_2.11-0.10.2.2\bin\windows ]

C:\kafka\kafka_2.11-0.10.2.2\bin\windows> zookeeper-server-start.bat ../../config/zookeeper.properties

 

6. cmd 창에서 kafka 실행 [ C:kafka\kafka_2.11-0.10.2.2\bin\windows ]

C:\kafka\kafka_2.11-0.10.2.2\bin\windows> kafka-server-start.bat ../../config/server.properties

 

7. cmd 창에서 kafka topic 생성

• topic 이름 - project
• IP 및 포트 - localhost:2181
• replication factor - 1
• partition 갯수 - 1

C:\kafka\kafka_2.11-0.10.2.2\bin\windows> kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic project

 

8. cmd 창에서 kafka consumer 실행(생성된 메시지를 받음)

C:\kafka\kafka_2.11-0.10.2.2\bin\windows> kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic project

 

9. cmd 창에서 kafka producer 실행 후 메시지 입력

C:\kafka\kafka_2.11-0.10.2.2\bin\windows> kafka-console-producer.bat --broker-list localhost:9092 --topic project

 

[ 실행 시, 오류 해결 방법 ]

 

* Kafka 실행 시 Java heap memory size 오류가 발생하는 경우

-> kafka-server-start.bat의 편집창 실행 후 KAFKA_HEAP_OPTS를 컴퓨터의 Java heap memory를 고려해서 변경

(기존의 64-bit OS의 1G를 512M으로 변경)