kafka windows에 설치 및 명령어

1. Kafka Download

 

kafka.apache.org/downloads

Apache Kafka

다운로드 받고 압축을 풀면 된다.

 

2. 실행방법

Zookeeper

D:\kafka> bin\windows\zookeeper-server-start.bat config\zookeeper.properties

압축푼 폴더로 가서 zookeeper를 실행시킨다.

2181포트로 뜬다.

 

kafka server

D:\kafka> bin\windows\kafka-server-start.bat config\server.properties

kafka server를 실행한다.

9092포트로 뜬다.

 

3. Kafka topic 명령어 

topic 생성

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic {topicName}

topic 조회

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

kafka 컨슈머 시작

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic {topicName}

아무것도 안뜨면 정상

 

Kafka 프로듀서 시작

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic {topicName}

이렇게 입력창이 떴을 때 내용을 입력하면

컨슈머에서 받는다.

Hi를 입력했다. 

컨슈머에서 받은 내용 

 

topic 내의 메세지 삭제

 

삭제 주기를 1초 등으로 줄여서 삭제하고 다시 늘릴 수 있다 

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic {topicName} --config retention.ms=1000

topic 삭제 후 다시 생성

 

#server.properties 에 delete.topic.enable=true 추가

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic {topicName}