下面给你一份**在 Ubuntu 上安装并配置 Kafka(以 Kafka 3.x + 自带 Zookeeper 为例)**的实用步骤,适合新手直接照做。
sudo apt update
sudo apt install -y openjdk-11-jdk
验证:
java -version
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
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个终端继续下面操作
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
看到 started (kafka.server.KafkaServer) 表示成功。
编辑:
nano /opt/kafka/config/server.properties
常见修改项:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://你的IP:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
改完重启 Kafka。
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入:
hello kafka
bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
sudo nano /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka
After=zookeeper.service
[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable kafka
advertised.listeners如果你需要:
告诉我你的使用场景,我可以直接给你对应方案。