你这个问题比较宽泛,我先按在 Ubuntu 上安装并配置 Kafka(含常见设置)来给你一个完整说明。如果你指的是某一具体设置(如消费者、生产者、集群、开机启动、权限等),可以再告诉我。
sudo apt update
sudo apt install openjdk-11-jdk -y
java -version
以 Kafka 3.x 为例:
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
/opt/kafka/config/server.properties
# 唯一 broker id(集群中不能重复)
broker.id=0
# 监听地址(本机)
listeners=PLAINTEXT://:9092
# 对外暴露地址(客户端用)
advertised.listeners=PLAINTEXT://localhost:9092
# 日志存储目录
log.dirs=/tmp/kafka-logs
# Zookeeper(Kafka 3.x 仍可用)
zookeeper.connect=localhost:2181
✅ Kafka 3.x 也可使用 KRaft(无 Zookeeper),如果你需要我可以单独讲。
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
/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 3 \
--replication-factor 1
查看:
kafka-topics.sh --list --bootstrap-server localhost:9092
sudo vim /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka
After=network.target zookeeper.service
[Service]
Type=simple
User=root
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable kafka
你可以直接告诉我你是想设:
我可以给你精确配置示例。