- zookeeper+kafka(>=0.09)
- php>=5.4
- librdkafka
- php-rdkafka
- swoole
include 'kafkaHighConsumer.php';
$kafkaobj = new kafkaHighConsumer();
$kafkaobj->Main(function () {
$this->topics = ['lowtest'];
$this->group_id = 'lowtest';
}, function ($message) {
echo 'offset:' . $message->offset . 'partition' . $message->partition . "\n";
});- $this->topics 是你的要订阅的topic
- $this->group_id 是你的分组名称
- Main方法的第一个参数是用的闭包设置参数，第二个参数是获取到的消息进行处理的方法
支持一次性开启多个单一分组的consumer，当然最好consumer的个数不能大于producers的个数
include 'taskKafkaConsumer.php';
$kafkaobj = new taskKafkaConsumer(function () {
$this->topics = ['lowtest'];
$this->group_id = 'lowtest';
$this->task_worker_num = 2;
}, function ($message) {
echo 'offset:' . $message->offset . 'partition' . $message->partition . "\n";
});- $this->topics 是你的要订阅的topic
- $this->group_id 是你的分组名称
- $this->task_worker_num 启动consumer的个数
- Main方法的第一个参数是用的闭包设置参数，第二个参数是获取到的消息进行处理的方法
include 'kafkaProducer.php';
$kafkaobj = new kafkaProducer();
$kafkaobj->Main('msg', function () {
$this->topic = 'lowtest';
});- $this->topic 设置送消息的topic（单一）
- Main方法的第一个参数是你要发送的消息，第二个是配置参数的匿名函数
需要建立一个配置文件，指定你的BORCKERS。
define('KAFKA_BORCKERS', 'ip地址：端口'); 
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent