php如何发送数据到kafka?
发布于 作者:苏南大叔 来源:程序如此灵动~

在苏南大叔给大家带来的大数据套装里面,kafka
仅仅是个小小的纽带。经常用于数据的发送及转移。在kafka
官方的例子中,其实并没有php
的相关实现版本。现在网上流传的kafka
的相关php
库,都是些编程爱好者们自己写的类库,所以就肯定不会有太统一的接口标准了。

下面以某个类库为例,展示相关的kafka
的php
扩展库使用。综合比较了几家kafka
的php
库,苏南大叔觉得下面的这个开源类库,nmred/kafka-php
,比较简洁方便一些。
composer
安装nmred/kafka-php
先要安装composer
的类库nmred/kafka-php
。composer
的基本使用问题,大家可以查看苏南大叔的composer
相关文章。
composer
安装nmred/kafka-php
的命令,如下:
当然,你也可以使用镜像加速下载,加速下载版的composer.json
如下图所示。
确定端口及topic
,查看kafka
版本号
我选择本地的端口是9092
,topic
是test1
,同时查看本地的kafka
版本是0.11.0.0
。这些在代码中都是要用到的。


生产者代码(异步)
生产者代码(同步)
这两个生产者的代码,可以用下列shell命令接收。
消费者代码
这个消费者代码,可以通过下面的shell命令发送数据。
值得特殊说明的是,这个消费者的代码,在网页里面执行也是可以的。页面会实时显示相关数据。估计php端是个无限长的endless状态。
相关链接
这个开源类库在github
上面叫做weiboad/kafka-php
,似乎是国人作品,所以有个中文文档。
小结
当然,大家要记得开启zookeeper
和kafka
,才能做这些实验。相关kafka
的安装问题,请点击这里查看:



你好,请问下monolog在这里是什么作用?
不错
原版带的这个monolog,个人觉得没用,所以注释掉了啊。一种日志工具罢了~