在安装php-kafka 扩展后,就可以开始编写 php 消费消息的脚本了,php-rdkafka 扩展提供了几种消息处理的方式
低级方式(Low level)
这种方式没有消费组的概念
<?php
$rk = new RdKafka\Consumer();
$rk-&g...
shanhuhai
8年前 (2017-09-18) 43995℃
21喜欢
PHP 安装kafka 扩展首先要安装 kafka的基础库 librdkafka
以下安装步骤在 Centos 6.x , php7+版本进行:
$ cd ~/download
$ wget -c https://github.com/edenhill/librdkafka/ar...
shanhuhai
8年前 (2017-09-14) 11927℃
2喜欢
环境
一共三台测试机
– 操作系统: centos7 ; hostname: c1 ; ip: 192.168.33.21
– 操作系统: centos7 ; hostname: c2 ; ip: 192.168.33.22
– 操作系统: c...
shanhuhai
9年前 (2016-02-24) 7239℃
0喜欢