linux下kafka安装与配置

• kafka依赖zookeeper，先下载并安装zookeeper：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.6.1/apache-zookeeper-3.6.1-bin.tar.gz
• 解压zookeeper

tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz

• 修改zookeeper配置

#将conf下的zoo_sample.cfg文件复制一份名称为zoo.cfg
cp zoo_sample.cfg zoo.cfg

•  指定zookeeper的数据目录和端口

• 启动zookeeper

#在bin目录下启动
./zkServer.sh  start

 

• 下载kafka安装包 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.5.0/kafka_2.12-2.5.0.tgz
• 解压安装包

tar -zxvf kafka_2.12-2.5.0.tgz

• 配置kafka

vim config/server.properties

• 修改listeners和zookeeper.connect配置，将localhost修改为本机IP（不修改会出现其它机器访问不到kafka）

 

• 启动kafka（如果是挂后台需要在命令后面加上“&”符号）

bin/kafka-server-start.sh config/server.properties

• 测试收发消息

#创建topic： test
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
#查询kafka中已经有的topic列表
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
#发送消息
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

 

#新开shell接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 

• 完成