[Apache Kafka] 설치 & 실행 & 명령어

0. 설치

Apache Kafka 사이트에 가서 파일을 다운받습니다.

 

kafka.apache.org/downloads

Apache Kafka

저는 스칼라 버전 2.12 를 사용하겠습니다.

 

Download file : kafka_2.12-2.7.0.tgz

 

압축을 풀어줍니다.

 

tar -xvf kafka_2.12-2.7.0.tgz

 

기본기능만 테스트 할 예정이니 설정파일은 디폴트 값으로 쓰겠습니다.

 

kafka 는 java가 있어야 실행이 됩니다.

java 설치되어있지 않는경우 설치를 해주셔야 합니다. (java 8 이상) 

---

1. Zookeeper 실행

 

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

 

---

2. Kafak 실행

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

---

3. Kafak Topic 생성

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

3-1. Kafak Topic 확인

 

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

---

4-1. Message Producer - 송신

 

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

4-2. Message Consumer - 수신

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

---

5-1. Consumer Group 확인

 

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

5-2. 해당 Group에 대해서 topic 정보 확인

 

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test_group --describe

 

5-3. 해당 Topic : partitions 변경

 

./bin/kafka-topics.sh --alter \
  --zookeeper localhost:2181 --partitions 2 --topic test