Java 설치
$ sudo dnf install java-11-openjdk wget vim
Kafka 다운로드
$ wget http://www-us.apache.org/dist/kafka/2.4.0/kafka_2.13-2.4.0.tgz
$ tar xzf kafka_2.13-2.4.0.tgz
$ mv kafka_2.13-2.4.0 /usr/local/kafka
//root 아닐 경우에는 sudo mv kafka_2.13-2.4.0 /usr/local/kafka
Unit file Setting
Zookeeper
$ vim /etc/systemd/system/zookeeper.service
[Unit]
Description=Apache Zookeeper server
Documentation=http://zookeeper.apache.org
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
ExecStart=/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties
ExecStop=/usr/local/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
Kafka
$ vim /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka Server
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service
[Service]
Type=simple
Environment="JAVA_HOME=/usr/lib/jvm/jre-11-openjdk"
ExecStart=/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
ExecStop=/usr/local/kafka/bin/kafka-server-stop.sh
[Install]
WantedBy=multi-user.target
$ systemctl daemon-reload //마무리
Kafka 실행
$ sudo systemctl start zookeeper //zookeeper 시작
$ sudo systemctl start kafka //kafka 시작
$ sudo systemctl status kafka //kafka active 확인
오류발생
zookeeper 실행 안되는 현상으로 kafka까지 active fail
아래 명령어로 프로세스 조회
$ journalctl -xe
'Database > Kafka' 카테고리의 다른 글
Kafka message(data) 보관주기 설정 (0) | 2020.07.30 |
---|---|
Kafka QuickStart (0) | 2020.07.30 |
[MacOS] Cloudkarafka와 python를 연동해서 메세지 전송하기 (0) | 2020.07.25 |
[MacOS] Cloudkarafka로 kafka 맛보기 (1) | 2020.07.24 |