微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

kafka基本用法

参考:

https://www.jianshu.com/p/fd8ce54e1156 (PHP操作kafka)

 

常识:

1,kafak依赖zookeeper,zookerper基于java

1,安装java环境,linux一般认安装了java

java -version #查看java版本

2,安装zookeeper

参考:https://www.runoob.com/w3cnote/zookeeper-setup.html

下载:

wget https://downloads.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
tar -zxvf zookeeper-3.4.14.tar.gz
cd zookeeper-3.4.14
cd conf/
cp zoo_sample.cfg zoo.cfg

配置:

vim zoo.cfg

tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
synclimit=2

启动:

cd ..
cd bin/
sh zkServer.sh start

 

3,安装kafka

参考:http://kafka.apache.org/quickstart

下载:

wget  https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz

tar -xzf kafka_2.13-2.8.0.tgz
cd kafka_2.13-2.8.0

 

4,安装PHP的kafka的扩展

git clone https://github.com/arnaud-lb/PHP-rdkafka.git
 
#生成configure文件
/Users/shiyibo/LNMP/PHP/bin/PHPize 
 
#编译安装
 ./configure --with-PHP-config=/Users/shiyibo/LNMP/PHP/bin/PHP-config
make
make install 
 
#在PHP.ini 文件中配置 rdkafka扩展
vim /Users/shiyibo/LNMP/PHP/etc/PHP.ini
extension=rdkafka.so
 
#查看扩展是否生效
$PHP -m | grep kafka

 

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐