본문 바로가기

Platform/Kafka

[Kafka] Zookeeper와 Kafka 기본 세팅

Zookeeper

https://dlcdn.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz

zoo.cfg 수정

# myid 생성(서버별 숫자 1,2,3으로 다르게)
echo 1 > /data/zookeeper/myid
  
cd /program/zookeeper/conf
cp zoo_sample.cfg zoo.cfg 
vi zoo.cfg
 
# zoo.cfg 설정
dataDir=/data/zookeeper
server.1=127.0.0.1:2888:3888
server.2=127.0.0.2:2888:3888
server.3=127.0.0.3:2888:3888
  
# 주기퍼 기동
cd /program/zookeeper/bin 
./zkServer.sh stop 
./zkServer.sh start
# 주기퍼 노드 확인
cd /program/zookeeper/bin
./zkCli.sh
 
WatchedEvent state:SyncConnected type:None path:null
[zk: localhost:2181(CONNECTED) 0] ls /
[znode, zookeeper]
 
 
[zk: localhost:2181(CONNECTED) 4] ls /znode/brokers/ids
[1,2,3]

Kafka

https://downloads.apache.org/kafka/3.2.1/

server.properties 설정

(서버별 숫자 1,2,3으로 다르게)
broker.id=1
advertised.listeners=PLAINTEXT://{서버ip}:9092
log.dirs=/data/kafka
zookeeper.connect=127.0.0.1:2181,127.0.0.2:2181,127.0.0.3:2181/znode
# kafka 구동
cd /program/kafka
./bin/kafka-server-stop.sh 
./bin/kafka-server-start.sh -daemon config/server.properties
jps