kafka基本用法

Posted 2021-05-22 细节决定专业

参考：

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