우분투 리눅스 아파치 카프카 설치하기

카프카 설치에 앞서 자바 설치

[linux] 리눅스 ubuntu(우분투) 자바(JDK11) 설치 하기

 

카프카 다운로드

 

Apache Kafka

최신버전 다운로드 및 설치

wget https://downloads.apache.org/kafka/3.5.1/kafka_2.12-3.5.1.tgz

 

압축해제 및 디렉토리 이동

$ tar kafka_2.12-3.5.1.tgz

$ mv kafka_2.12-3.5.1.tgz /opt/kafka

 

 

서비스 만들기

 

주키퍼 서비스

 

$ vi /etc/systemd/system/zookeeper.service

[Unit]
Description=Apache Zookeeper service
Documentation=http://zookeeper.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal

[Install]
WantedBy=multi-user.target

 

카프카 서비스

$ vi /etc/systemd/system/kafka.service

[Unit]
Description=Apache Kafka Service
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service

[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh

[Install]
WantedBy=multi-user.target

 

서비스 리로드

$ systemctl daemon-reload

 

서비스 실행

$ systemctl start zookeeper

$ systemctl start kafka

 

서비스 확인

$ systemctl status zookeeper

$ systemctl status kafka

 

여기까지 설치 완료

---

토픽 생성 및 메시지 보내기 받기

 

 

토픽 생성

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic test --create

 

토픽 리스트

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

 

메시지 보내기

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

 

메시지 수신하기 

다른 쉘 하나 연결하여 실행

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