PHP使⽤kafka⼊门
第⼀步,kafka安装使⽤⼊门
0:环境准备,Linux环境(CentOS为例),wget命令,git命令,java8
1:下载kafka
2:解压
tar -zxvf kafka_2.12-2.
3:进⼊⽬录
cd kafka_2.12-2.7.0
4:启动ZooKeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
5:这时窗⼝会停留在监听状态,再新建⼀个窗⼝,同⽬录下启动kafka
bin/kafka-server-start.sh config/server.properties
php8兼容php7吗
6:再新建⼀个窗⼝,创建⼀个topic(topic⽤来存储数据)
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
7:在这个topic上写⼊⼀些内容,使⽤producer(⽣产者)
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
这时会出现输⼊光标,可以输⼊⼀些字符,然后按回车⽣产数据。
8:再新建⼀个窗⼝,使⽤consumer(消费者)来使⽤刚刚⽣产者⽣产的数据
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server
localhost:9092
这时可以⽐对7和8两个窗⼝,7窗⼝的输⼊,会在8窗⼝上输出。
这时,我们就完成了kaf ka的⼀个基本流程。包括使⽤zooke e p e r来管理kaf ka进程,新建top ic和

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。