下面给你一份**在 Ubuntu 上安装并配置 Kafka(单机版)**的常用步骤,适合测试/学习使用。
Kafka 依赖 JVM(推荐 Java 8 或 11)
sudo apt update
sudo apt install openjdk-11-jdk -y
检查:
java -version
Kafka 3.x 开始支持 KRaft 模式(无 Zookeeper),但新手建议先按 Zookeeper 方式。
sudo apt install zookeeperd -y
启动:
sudo systemctl start zookeeper
sudo systemctl enable zookeeper
cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka
sudo vim /opt/kafka/config/server.properties
常用配置:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
后台运行:
nohup /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties > kafka.log 2>&1 &
/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 服务文件,需要的话我可以给你完整示例。
server.properties 中 JVM 参数advertised.listeners如果你是要:
告诉我,我可以给你对应版本。