https://kafka.apache.org/quickstart
- 安装 http://kafka.apache.org/downloads
- 解压缩
tar -zxvf kafka_2.12-3.0.0.tgz
- 编辑配置文件
vim config/server.properties
# 集群中当前broker唯一id broker.id=0 # 换成自己电脑的ip listeners=PLAINTEXT://localhost:9092 # 日志存放路径 log.dirs=../kafka-data-log/kafka-logs 默认的分区数 num.partitions=1 # 连接的zk地址 zookeeper.connect=localhost:2181
- 启动
bin/kafka-server-start.sh -daemon ../config/server.properties
- 检查是否启动
- ps -aux |grep ../config/server.properties
- ps -aux |grep kafka
- 检查zk节点
集群搭建
- 复制3分kafka安装包
分别修改配置文件
broker.id=0 listeners=PLAINTEXT://127.0.0.1:9092 log.dirs=../kafka-data-log/kafka-logs-0
broker.id=1 listeners=PLAINTEXT://127.0.0.1:9093 log.dirs=../kafka-data-log/kafka-logs-1
broker.id=2 listeners=PLAINTEXT://127.0.0.1:9094 log.dirs=../kafka-data-log/kafka-logs-2
- 分别启动
- 检查是否启动成功
可视化管理工具