Создаем пользователя
$ sudo useradd kafka -m
$ sudo passwd kafka
$ sudo adduser kafka sudo
$ su -l kafka
Ставим Java
$ sudo apt update
$ sudo apt install openjdk-11-jre-headless -y
$ java --version
Ставим кафка
wget https://dlcdn.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
sudo mkdir /opt/kafka
sudo tar -xzf kafka_2.13-3.2.0.tgz
sudo mv kafka_2.13-3.2.0/* /opt/kafka
Добавляем сервисы
sudo vim /etc/systemd/system/kafka.service
kafka.service
[Unit]
Description=Kafka Broker
After=zookeeper.service
Requires=zookeeper.service
[Service]
Type=simple
User=kafka
ExecStart=/bin/sh -c ‘/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties > /var/log/kafka/kafka.log 2>&1’
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
[свернуть]
sudo vim /etc/systemd/system/zookeeper.service
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
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
[свернуть]