下面给你一份**在 Debian 上安装和配置 Kafka(单机版)**的实用步骤,适用于 Debian 11 / 12,也基本适用于 Ubuntu。
sudo apt update
sudo apt upgrade -y
Kafka 3.x 推荐 Java 8 / 11 / 17
sudo apt install -y openjdk-17-jdk
验证:
java -version
sudo useradd -m -s /bin/bash kafka
sudo su - kafka
到官网复制最新版本地址:https://kafka.apache.org/downloads
cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka
设置权限:
sudo chown -R kafka:kafka /opt/kafka
cd /opt/kafka
vi config/zookeeper.properties
常见配置:
dataDir=/opt/kafka/zookeeper-data
clientPort=2181
创建目录:
mkdir -p /opt/kafka/zookeeper-data
vi config/server.properties
基本配置(单机):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/opt/kafka/kafka-logs
num.partitions=1
zookeeper.connect=localhost:2181
创建日志目录:
mkdir -p /opt/kafka/kafka-logs
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
查看进程:
jps
应看到:
/opt/kafka/bin/kafka-topics.sh \
--create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
/opt/kafka/bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入:
hello kafka
/opt/kafka/bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
sudo vi /etc/systemd/system/zookeeper.service
[Unit]
Description=Zookeeper
After=network.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
sudo vi /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka
After=zookeeper.service
[Service]
Type=simple
User=kafka
ExecStart=/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
sudo systemctl daemon-reload
sudo systemctl enable zookeeper
sudo systemctl enable kafka
sudo systemctl start zookeeper
sudo systemctl start kafka
如果你不想用 Zookeeper:
kafka-storage.sh 初始化需要的话我可以单独给你 KRaft 模式配置教程。
如果你告诉我:
我可以给你更精确的配置。