下面给你一份在 Debian 系统上安装和配置 Apache Kafka 的完整步骤(单机版),适合新手或测试环境。
sudo apt update
sudo apt upgrade -y
Kafka 需要 Java 8 或以上版本。
sudo apt install openjdk-17-jdk -y
验证:
java -version
sudo mkdir -p /opt/kafka
cd /opt/kafka
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
可在 https://kafka.apache.org/downloads 查看最新版本
tar -xvzf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1/* .
rm -rf kafka_2.13-3.6.1 kafka_2.13-3.6.1.tgz
/opt/kafka
├── config # 配置文件
├── bin # 启动脚本
├── logs
Kafka 3.x 仍可用 Zookeeper,也可使用 KRaft(无 Zookeeper),这里先用 Zookeeper。
编辑:
nano config/zookeeper.properties
默认即可:
dataDir=/tmp/zookeeper
clientPort=2181
bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行(推荐):
nano start-zookeeper.sh
#!/bin/bash
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties &
chmod +x start-zookeeper.sh
./start-zookeeper.sh
编辑:
nano config/server.properties
常见配置项(可保持默认):
broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
如需远程访问:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092
bin/kafka-server-start.sh config/server.properties
后台运行:
nano start-kafka.sh
#!/bin/bash
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &
chmod +x start-kafka.sh
./start-kafka.sh
bin/kafka-topics.sh --create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
如果你需要,我可以帮你写 Kafka + Zookeeper 的 systemd 服务文件,这样服务器重启后自动启动。
编辑:
nano bin/kafka-server-start.sh
调整:
export KAFKA_HEAP_OPTS="-Xmx512M -Xms256M"
如果你想要 Kafka 3.x 无 Zookeeper 配置,我也可以单独给你一份步骤。
如果你告诉我:
我可以给你更精确的配置方案。