kafka单机搭建
时间: 2025-03-17 17:15:37 浏览: 40
### Kafka 单机安装与配置教程
#### 准备工作
确保已安装并配置好 Java 运行环境,因为 Kafka 是基于 Scala 开发的工具,依赖于 Java 环境[^4]。
#### 下载与解压 Kafka
下载最新版本的 Kafka 并将其解压缩至目标路径。例如:
```bash
wget https://downloads.apache.org/kafka/2.5.0/kafka_2.12-2.5.0.tgz
tar -xzf kafka_2.12-2.5.0.tgz
cd kafka_2.12-2.5.0
```
#### 配置文件调整
进入 `config` 文件夹,找到 `server.properties` 文件,并对其进行必要的修改。以下是几个重要参数说明:
- 修改监听地址为实际 IP 地址而非默认的 localhost。例如设置如下属性以避免连接问题:
```properties
listeners=PLAINTEXT://<your-ip>:9092
advertised.listeners=PLAINTEXT://<your-ip>:9092
```
如果不更改上述两项,默认情况下可能会导致客户端无法正确访问 Kafka 实例[^2]。
- 设置数据存储目录(可选),通过指定 log.dirs 参数来定义日志保存位置:
```properties
log.dirs=/tmp/kafka-logs
```
完成以上改动后保存退出编辑器。
#### 启动 Zookeeper 和 Kafka Server
Kafka 使用 Apache ZooKeeper 来管理集群元数据,在单节点模式下也需要先启动它。
```bash
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
```
接着再开启 Kafka broker 服务进程:
```bash
./bin/kafka-server-start.sh -daemon config/server.properties
```
此时可以通过 ps 命令验证两个后台程序均已正常运行状态存在[^3]。
#### 创建 Topic 及测试消息收发功能
利用自带脚本快速建立一个新的 topic 名称为 test 的队列结构体实例化操作命令如下所示:
```bash
./bin/kafka-topics.sh --bootstrap-server <your-ip>:9092 --create --topic test --partitions 1 --replication-factor 1
```
随后分别打开两个终端窗口用于模拟生产者发送以及消费者接收端逻辑行为过程演示效果展示出来即可证明整个流程搭建顺利完成[^1]。
---
阅读全文
相关推荐

















