[kafka] ubuntu 18.04에 kafka 설치

1. open jdk 설치

sudo su 
apt update 
apt install openjdk-11-jdk -y

---

2. kafka 유저생성

useradd -d /opt/kafka -s /bin/bash kafka -m 
passwd kafka

---

3. tar 다운로드 (2.5.0 기준) 및 압축풀기 / 폴더 오너변경

cd /opt
wget http://apache.mirror.cdnetworks.com/kafka/2.5.0/kafka_2.12-2.5.0.tgz
mkdir -p /opt/kafka
tar -xf kafka_2.12-2.5.0.tgz -C /opt/kafka --strip-components=1
chown -R kafka:kafka /opt/kafka

---

4. server.properties 수정

vi /opt/kafka/config/server.properties

delete.topic.enable = true 마지막줄 추가

---

5. 서비스 등록

vi /lib/systemd/system/zookeeper.service

[Unit]
Requires=network.target remote-fs.target
After=network.target remote-fs.target

[Service]
Type=simple
User=kafka
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 /lib/systemd/system/kafka.service

[Unit]
Requires=zookeeper.service
After=zookeeper.service

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

[Install]
WantedBy=multi-user.target

---

6. 서비스 실행 및 등록

systemctl daemon-reload 
systemctl start zookeeper 
systemctl enable zookeeper 
systemctl start kafka 
systemctl enable kafka

---

7. kafka 계정 접속 및 토픽생성

su - kafka
cd bin/
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic TestTopicName