每次学一个东西从基础的开始,循序渐进。
不急不躁,路还很长。
所有教程都是学习汪文君大神的kafka教程的。
一、部署
这里选的kafka版本是 0.10.2.1 下载连接 https://download.csdn.net/download/lsl13551615708/9881118
0.这里我是在自己虚拟机上安装的,虚拟机的安装可以搜一下。如果确实搜不到也不急的话可以留言。虚拟机安装好后记得桥接网络并挂载共享文件。
1.在/usr/local下创建如下路径 /usr/local/kafka/demo ,执行kafka的安装文件 tar -xzvf kafka_2.10-0.10.2.1 -c demo
2.在安装后的路径下创建同级目录 data用于存放kafka和zk的数据信息
3.配置zk和kafka
进入安装路径下的config目录,输入命令vim zookeeper.properties
修改dataDir = /usr/local/kafka/demo/data/zk
clientPort=2181
:wq!保存后退出
输入命令vim server.properties
修改
log.dirs=/usr/local/kafka/demo/data/kafka
zookeeper.connect=ip地址:2181
listeners=PLAINTEXT://ip地址:9092
二、启动并测试
1.启动zk
这里用的是kafka自带的zk,毕竟只是学习
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
netstat -na|grep 2181 查看启动是否成功
2.启动kafka
bin/kafka-server-start.sh -daemon config/server.properties
netstat -na|grep 9092 查看是否启动
tail -200f logs/server.log 查看是否报错 如果这里报什么主机名不匹配的错误 那么 配置hosts 你的ip 主机名
3.创建topic
bin/kafka-topics.sh --create --topic test --zookeeper localhost:2181 --partitons 1 --replication-factor 1 关于kafka的原理 和接口解释可以浏览 https://blog.csdn.net/ychenfeng/article/details/74980531
创建成功会返回 created topic "test"
4.创建producer,并生产数据
bin/kafka-console-producer.sh --topic test --broker-list 192.168.31.187:9092 这里的ip改成你的虚拟机ip
然后输入你想生产的数据
5.创建consumer
另外起一个终端。
bin/kafka-console-consumer.sh --topic test --bootstrap-server 192.168.31.187:9092 这里ip端口换成虚拟机ip端口
6.测试
在producer终端输入任何信息按回车 consumer就可以收到消息。测试成功
原文地址:https://www.cnblogs.com/Iran1112/p/9279842.html