一、kafka配置:
注意1:
在配置使用kafka前提必须确保zookeeper已经安装配置好了
二、1、zookeeper安装
1、验证zookeeper包是否完整
sha256sum +包名
2、解压
tar -zxvf +包名
3、解压后
4、创建存放数据的文件夹
mkdir /data/datalake
mkdir /data/datalake/zkdata
5、进入conf 之后,拷贝多一份文件zoo.cfg作为配置
cp zoo_sample.cfg zoo.cfg
6.编辑zoo.cfg
vi zoo.cfg
7、添加内容为启动日志保存的路径
DataDir=/data/zookeeper
DataLogDir=/data/datalake/zkdata
8、然后进入zookeeper的 bin目录下 启动
zkServer.sh start
也可以配置zookeeper的环境变量,这样就不用每次进入目录下启动了
三、开始配置kafka
1、解压之前验证压缩包是否完整
sha256sum +包名
2、解压
tar -zxvf +包名
3、进入解压后的kafka文件的config 修改 server.properties
修改三处:
host.name =ip ----你的ip地址
listeners = PLAINTEXT://ip:9092 ---ip写你的ip地址
advertised.listeners=PLAINTEXT://ip:9092 ----ip写你的ip地址
4.启动kafka:
务必在kafka的文件目录下
bin/kafka-server-start.sh config/server.properties &
5.验证kafka是否启动
jps -ml
6.查看端口占用情况
netstat -tunlp|egrep "(2181|9092)"
7.测试kafka是否能正常使用
复制机器3台或更多(看个人情况),需要在kafka文件目录下,使用topics.sh 脚本 创建一个zookeeper 监听端口 数目, 文件
kafka 生产测试
测试命令如下:
7.1. 创建topic
./bin/kafka-topics.sh --bootstrap-server ip:9092 --create --replication-factor 1 --partitions 1 --topic test -----ip为你的地址
7.2.启动生产模式
./bin/kafka-console-producer.sh --broker-list 192.168.137.104:9092 --topic test
注意:地址是由自己的kafka下config中的server.properties
此处为消费者操作输入窗口
例子
kafka -----此处输入kafka
7.3.消费者的监听窗口
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.137.104:9092 --topic test --
监听页面显示
kafka -----此处显示监听到输入的事件
文章到此结束,kafka配置成功!感谢阅读!小白心得,还望轻喷!
版权归原作者 su小哲 所有, 如有侵权,请联系我们删除。