1. 请先下载安装文件, java 环境需提前安装, 解压到指定目录:
tar -zxvf kafka_2.11-2.3.1.tgz -C /root/soft/
从官网下载文件, 上传到 CentOS 虚拟机指定路径下, 当前 download 文件夹下面
解压到指定目录 soft 文件夹下面:
2. 创建 zk 日志目录.
mkdir zklogs
3. 查看是否启动成功,
ps -ef | grep zookeeper
4. 启动 zookeeper
nohup bin/zookeeper-server-start.sh ./config/zookeeper.properties &
5. 修改 kafka 配置
VIM config/server.properties
执行命令 vi config/server.properties 修改 kafka 的配置信息
修改 advertised.host.name 和 advertised.port 信息
修改日志文件路径:
修改 log.dirs=/root/soft/kafka-logs 为 log.dirs=/root/soft/kafka/logs 该参数为 kafka 日志文件存放路径
- advertised.host.name=192.168.132.152
- advertised.port=9092
- log.dirs=/root/soft/kafka/logs
6. 启动 kafka
nohup bin/kafka-server-start.sh ./config/server.properties
执行命令 ps -ef | grep kafka 查看 kafka 是否启动成功
7. 创建 mytest 主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest
获取所有 topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
8. 生产测试消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytest
9. 消费消息
bin/kafka-console-consumer.sh --Bootstrap-server localhost:9092 --topic mytest --from-beginning
kafka 和 java 安装文件网盘下载地址:
链接: https://pan.baidu.com/s/1DhbzsKvqB7Y3S9QJQUUK9A
提取码: zim2
来源: http://www.bubuko.com/infodetail-3258629.html