kafka初体验
安装java环境:
下载java环境包:wget https://download.oracle.com/java/17/latest/jdk-17_linux-x64_bin.tar.gz
解压后,配置环境变量:
vim /etc/profile
进入文本编辑,"shift+g"定位到文件尾, 另起一行写下如下数据
export JAVA_HOME=/usr/local/src/jdk1.8.0_171 (根据自己的完整路径修改)
export PATH=$PATH:$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
保存退出
让环境变量生效 :
source /etc/profile
验证是否安装成功: java -version
注意zookeeper与kafka下zookeeper的版本 这里使用zookeeper3.7.0 + kafka2.8.0 安装zookeeper: 下载zookeeper包 下载后解压
进入conf目录下,复制 zoo_sample.cfg 文件为zoo.cfg
cd ./apache-zookeeper-3.7.0/conf cp zoo_sample.cfg ./zoo.cfg
bin目录下启动服务:
#启动
sh zkServer.sh start
#查看启动状态
sh ./zkServer.sh status
启动成功
安装kafka: 下载kafka包 下载后解压
进入config目录配置集群vim server.properties
- 把broker.id改0,1,2 三台机器不一样
broker.id=0
- 把listeners生效,并加上本机ip
listeners=PLAINTEXT://localhost:9092,去掉#号,这里不要写死地址,使用localhost,写死后连不上
- 指定zookeeper连接地址,改为zookeeper服务器地址
zookeeper.connect=zookeeper服务器地址:2181
- 启动kafka,三台机器启动,进入bin目录,执行
sh kafka-server-start.sh -daemon ../config/server.properties
查看zookeeper
ps -ef|grep zookeeper
- 可以进入log目录看kafka日志
tail -f server.log
文件是否有报错kafka启动完成后,查看zookeeper集群连接情况 : 进入apache-zookeeper-3.7.0/bin目录执行
sh zkCli.sh #查看 执行ls / #查看连接情况ls /brokers/ids
任意一台机器 新建topic:
sh kafka-topics.sh --create --zookeeper 192.168.88.137:2181 --replication-factor 1 --partitions 1 --topic test
#说明
#192.168.88.137:2181 ###这是zookeeper服务ip+端口号
#test ###这是topic
使用任意一台kafka服务器做生产者:
sh kafka-console-producer.sh --broker-list 192.168.88.132:9092 --topic test
ip不行时试试127.0.0.1或者修改kafka->config->server.properties
# 允许外部端口连接
listeners=PLAINTEXT://0.0.0.0:9092
# 外部代理地址
advertised.listeners=PLAINTEXT://121.201.64.12:9092
kafka消费:
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test1 --from-beginning
猜你喜欢
PHP使用Elasticsearch搜索引擎
阅读 679PHP使用Elasticsearch搜索引擎实现查询
redis秒杀
阅读 846基于redis 实现并发情况的超卖超买解决方案
Larave|Lumen 配合Swoole 加速
阅读 883为什么要用swoole来加速laravel呢?
Laravel邮箱推送
阅读 819Laravel发送邮件
swoole 极简聊天室
阅读 571五分钟教你写超简单的swoole聊天室
PHP定时任务
阅读 514PHP框架Laravel定时任务的实现
Elasticsearch搜索引擎初体验
阅读 590Elasticsearch安装使用教程
Linux ab 测压
阅读 779linux下ab网站压力测试命令