Создаем пользователя
$ 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 /usr/local/kafka-server
sudo tar -xzf kafka_2.13-3.2.0.tgz
sudo mv kafka_2.13-3.2.0/* /usr/local/kafka-server
Добавляем сервисы
sudo vim /etc/systemd/system/kafka.service
kafka.service
[Unit]
Description=Apache Kafka Server
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service
After=zookeeper.service
[Service]
Type=simple
Environment="JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64"
ExecStart=/usr/local/kafka-server/bin/kafka-server-start.sh /usr/local/kafka-server/config/server.properties
ExecStop=/usr/local/kafka-server/bin/kafka-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
[свернуть]
sudo vim /etc/systemd/system/zookeeper.service
zookeeper.service
[Unit]
Description=Apache Zookeeper Server
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
ExecStart=/usr/local/kafka-server/bin/zookeeper-server-start.sh /usr/local/kafka-server/config/zookeeper.properties
ExecStop=/usr/local/kafka-server/bin/zookeeper-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
[свернуть]
Запустим сервисы
sudo systemctl start kafka
sudo systemctl start zookeeper
Если нужно добавляем в автозапуск
sudo systemctl enable zookeeper
sudo systemctl enable kafka