下面按在 Debian 上安装并配置 Kafka(单机示例)来讲,适合入门和测试环境。如果你要的是集群 / 生产配置,我也可以再补。
Kafka 3.x 推荐 Java 8 / 11 / 17
sudo apt update
sudo apt install -y openjdk-17-jdk
验证:
java -version
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 nano /opt/kafka/config/zookeeper.properties
常见修改:
dataDir=/opt/kafka/zookeeper-data
clientPort=2181
创建目录:
sudo mkdir -p /opt/kafka/zookeeper-data
编辑:
sudo nano /opt/kafka/config/server.properties
关键配置(单机):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/opt/kafka/kafka-logs
zookeeper.connect=localhost:2181
创建日志目录:
sudo mkdir -p /opt/kafka/kafka-logs
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
(后台运行加 & 或用 systemd)
新开终端:
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
/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
/opt/kafka/bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
如果你想开机自启,我可以帮你写 systemd 的 zookeeper + kafka 服务文件。
logs/ 下日志advertised.listeners 为公网 IP如果你告诉我:
我可以给你更精确的配置方案。