kafka 서버 설치하기

CentOS7을 기준으로 작성한 가이드 입니다.

 

JDK 설치

# sudo yum install java-1.8.0-openjdk-devel
# java -version

 

kafka 서버 Install

# wget --no-check-certificate https://archive.apache.org/dist/kafka/3.2.0/kafka_2.12-3.2.0.tgz
# tar xvf kafka_2.12-3.2.0.tgz
# cd kafka_2.12-3.2.0

Configuration

# cd config

# vi server.properties
//[31번 라인 정도에 있는 다음 내용 주석 해제]
listeners=PLAINTEXT://:9092

//[36번 라인 정도에 있는 다음 내용 주석 해제 후 다음과 같이 내용 변경]
advertised.listeners=PLAINTEXT://localhost:9092

zookeeper 데몬 실행

# {kafka_home}/bin/zookeeper-server-start.sh -daemon /root/kafka_2.12-3.2.0/config/zookeeper.properties
# ps -ef | grep zookeeper

kafka 데몬 실행

# {kafka_home}/bin/kafka-server-start.sh -daemon  /root/kafka_2.12-3.2.0/config/server.properties
# ps -ef | grep kafka

Topic 생성/삭제

{kafka_home}/bin에서 다음 실행
// [Topic 생성]
# kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafka-test
# kafka-topics.sh --list --bootstrap-server localhost:9092

// [Topic 삭제]
# kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic kafka-test
# kafka-topics.sh --list --bootstrap-server localhost:9092