반응형

카프카를 설치해보자...우선 다운로드 받는다...

 

https://kafka.apache.org/downloads

 

Apache Kafka

Apache Kafka: A Distributed Streaming Platform.

kafka.apache.org

 

#wget http://mirror.apache-kr.org/kafka/2.2.0/kafka_2.11-2.2.0.tgz

불러오는 중입니다...

#tar zxvf kafka_2.11-2.2.0.tgz

불러오는 중입니다...

 

#ln -s kafka_2.11-2.2.0 kafka

#cd kafka

#mkdir data1 data2

생성해주고...

 

#vi /root/kafka/config/server.properties

broker.id=1

log.dirs=/root/kafka/data1,/root/kafka/data2

zookeeper.connect=kafka1:2181,kafka2:2181,kafka3:2181

 

이렇게 세부분을 수정한다.

 

 

카프카 실행(반드시 주키퍼를 실행후 실행)

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

 

카프카 토픽 생성

#/root/kafka/bin/kafka-topics.sh --zookeeper kafka1:2181,kafka2:2181,kafka3:2181 --replication-factor 1 --partitions 1 --topic topic01 --create

 

카프카 토픽에 메세지 등록

#/root/kafka/bin/kafka-console-producer.sh --broker-list kafka1:9092,kafka2:9092,kafka3:9092 --topic topic01

 

등록된 토픽 확인

#/root/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic topic01 --from-beginning

 

이런식으로 각 서버에서 다 해보면 완료

 

반응형

+ Recent posts