Kafka单机环境搭建简记

共计 1646 个字符，预计需要花费 5 分钟才能阅读完成。

最近在搞 kettle 整合 kafka producer 插件，于是自己搭建了一套单机的 kafka 环境，以便用于测试。现整理如下的笔记，发上来和大家分享。后续还会有 kafka 的研究笔记，依然会与大家分享！

1 kafka 环境搭建

1.1 kafka 单机环境搭建

(1)、解压 kafka_2.11-1.1.0.tgz，得到“kafka_2.11-1.1.0”文件夹。

(2)、kafka 需要安装 zookee 使用，但 kafka 集成 zookeeper, 在单机搭建时可直接使用。使用需配置 kafka_2.11-1.1.0/config 下的“zookeeper.properties”。

(3)、配置“zookeeper.properties”。修改 dataDir 和 clientPort。前者是快照存放地址 (自己随意配置)，后者是客户端连接 zookeeper 服务的端口。

(4)、配置 kafka_2.11-1.1.0/config 下的“server.properties”，修改 log.dirs 和 zookeeper.connect。前者是日志存放文件夹，后者是 zookeeper 连接地址（端口和 clientPort 保持一致）。

到此，kafka 的单机环境就搭建成功了。

2 kafka 的相关命令

3 kafka 的简单使用

(1)、进入”kafka_2.11-1.1.0”文件夹，运行”开启 kafka 自带 zookeeper”命令 (最好用后台模式)。记得进入日志中，检查下启动是否有错误。

(2)、确认 zookeeper 启动成功后，继续在当前目录，运行“开启 kafka”命令 (依然用后台模式)。记得检查日志。

(3)、确认两者启动完毕后，运行“创建 kafka 主题”命令。显示红框中内容，即为创建成功。

(4)、继续在此目录下，运行“创建 kafka 生产者”的命令。kafka 默认端口是 9092。(图片里我自己改成了 9192，没改的直接用 9092 端口)。如图，我发送了”qpf_test”的消息。

(5)、另起一个终端，仍在相同目录下运行“创建 kafka 消费者”的命令。消费者会收到生产者发来的消息。如图，我接收到了之前发的”qpf_test”的消息。

：