kafka + zookeeper 설치

1. java 설치 확인

java -version

2. 미설치 시 설치 진행

sudo apt-get install openjdk-8-jdk

3. kafka 다운로드

wget [http://apache.mirror.cdnetworks.com/kafka/2.4.0/kafka_2.13-2.4.0.tgz](http://apache.mirror.cdnetworks.com/kafka/2.4.0/kafka_2.13-2.4.0.tgz)

tar -zxf kafka_2.13-2.4.0.tgz

4. 설정파일 확인

vi config/zookeeper.properties

vi config/server.properties

5. zookeeper 구동

bin/zookeeper-server-stop.sh

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

6. kafka 구동

bin/kafka-server-stop.sh

bin/kafka-server-start.sh -daemon config/server.properties

7. topic 확인

bin/kafka-topics.sh --list --zookeeper localhost:2181

8. topic 생성

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

9. topic 상세정보

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

10. topic 삭제

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

• 토픽 리스트 조회

/usr/local/kafka/bin/kafka-topics.sh --list --zookeeper 172.31.19.30:2181/luna-kafka

• 토픽 상세 정보

/usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper 172.31.19.30:2181/luna-kafka --topic cafe24-member-new-insert-topic

• 토픽 생성

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper 172.31.19.30:2181/luna-kafka --replication-factor 1 --partitions 1 --topic cafe24-member-new-insert-topic

• 토픽 삭제

/usr/local/kafka/bin/kafka-topics.sh --delete --zookeeper 172.31.19.30:2181/luna-kafka --topic test-dean