kafka centos安装发送消费消息

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