一、引入：为何选择Kafka？

选择合适的消息队列中间件至关关键。Kafka以其高大吞吐量、可伸缩性和持久化能力在众许多消息队列中脱颖而出。接下来我们将深厚入了解怎么在Ubuntu上成功部署Kafka。

二、 准备阶段：周围搭建

1. 安装Java JDK

Kafka基于Java开发，所以呢先说说需要确保系统中安装了Java Development Kit 。

sudo apt update
sudo apt install openjdk-11-jdk

2. 下载与解压Kafka

从Apache Kafka官网下载最新鲜稳稳当当版Kafka安装包。

wget https://dlcdn.apache.org/kafka/3.5.1/kafka_2.13-3.5.1.tgz
tar -xzf kafka_2.13-3.5.1.tgz

三、配置Kafka

1. 修改配置文件

Kafka的配置文件位于解压后的config目录中。

broker.id=1
listeners=PLAINTEXT://:9092
log.dirs=/path/to/log/directory

2. 设置周围变量

将Kafka的bin目录添加到系统的PATH周围变量中，以便全局访问Kafka命令。

四、 启动Kafka

1. 启动Zookeeper

先说说需要启动Zookeeper服务，基本上原因是Kafka依赖Zookeeper进行协调。

bin/zookeeper-server-start.sh config/zookeeper.properties

2. 启动Kafka服务器

接下来 启动Kafka服务器：

bin/kafka-server-start.sh config/server.properties

五、测试Kafka

1. 创建主题

用以下命令创建一个名为“test”的主题：

bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

2. 发送消息

向“test”主题发送一条消息：

bin/kafka-console-produce.sh --topic test --bootstrap-server localhost:9092
This is a test message

3. 消费消息

从“test”主题读取消息：

bin/kafka-console-consume.sh --topic test --from-beginning --bootstrap-server localhost:9092

---