php kafka consumer.zip

php-kafka-consumer 主要是对 php_rdkafka 的 consumer 的 API 进行一层封装,增加了原程序中所没有的与 zookeeper 交互的功能。在此基础上实现了 rebalance 功能以及 group 功能。 经过简单的压力测试,单个进程的消费能力能达到每秒钟7.8W条,压测详细内容见压力测试。依赖php_zookeeperphp_rdkafka (建议使用1.0.0版本)librdkafka(建议使用0.9.1版本)使用<?php include 'consumer.php'; function call_back_func($msg) {