96SEO 2025-06-30 12:18 4
高大效的消息队列系统已成为许许多应用场景的必备工具。Apache Kafka因其高大性能、可 性等优良处,成为了业界首选。本文将带你深厚入了解怎么在Ubuntu上配置Kafka,让你轻巧松上手,构建高大效的消息队列系统。

在开头配置Kafka之前,我们需要做优良以下准备干活:
| 柔软件 | 版本 |
|---|---|
| Ubuntu | 18.04 |
| Java | OpenJDK 8 |
| Zookeeper | 3.4.14 |
| Kafka | 3.5.2 |
先说说我们需要安装Java。用以下命令安装OpenJDK 8:
sudo apt update
sudo apt install openjdk-8-jdk
安装完成后 验证Java是不是正确安装:
java -version
Zookeeper是Kafka的依赖服务,我们需要先配置并启动Zookeeper。
1. 下载Zookeeper安装包
wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
2. 解压安装包
tar -xzf zookeeper-3.4.14.tar.gz
3. 进入Zookeeper目录, 复制配置文件
cd zookeeper-3.4.14
cp conf/zoo_sample.cfg conf/zoo.cfg
4. 修改配置文件
tickTime=2000
dataDir=/var/lib/zookeeper
clientPort=2181
5. 启动Zookeeper
sudo /usr/local/zookeeper/bin/zookeeper-server-start.sh conf/zoo.cfg
1. 下载Kafka安装包
wget https://archive.apache.org/dist/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -xzf kafka_2.12-3.5.2.tgz
3. 移动Kafka目录到指定位置
sudo mv kafka_2.12-3.5.2 /usr/local/kafka
4. 修改Kafka配置文件
sudo nano /usr/local/kafka/config/server.properties
修改以下配置项:
listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/usr/local/kafka/logs
zookeeper.connect=localhost:2181
5. 启动Kafka
sudo /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
1. 创建Topic
sudo /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2. 验证Topic是不是创建成功
sudo /usr/local/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
3. 生产者发送消息
sudo /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a test message
4. 消费者接收消息
sudo /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
This is a test message
本文详细介绍了在Ubuntu上配置Kafka的步骤,包括安装Java、Zookeeper、Kafka以及配置和测试。希望本文能帮你轻巧松上手Apache Kafka,构建高大效的消息队列系统。
Demand feedback