php-kafka-consumer 依赖使用

程序名称：php-kafka-consumer 依赖使用

授权协议: MIT

操作系统: 跨平台

开发语言: PHP

php-kafka-consumer 依赖使用 介绍

PHP-kafka-consumer 主要是对 PHP_rdkafka 的 consumer 的 API 进行一层封装，增加了原程序中所没有的与
zookeeper 交互的功能。在此基础上实现了 rebalance 功能以及 group 功能。
经过简单的压力测试，单个进程的消费能力能达到每秒钟7.8W条，压测详细内容见压力测试。

依赖

PHP_zookeeper

PHP_rdkafka （建议使用1.0.0版本）

librdkafka（建议使用0.9.1版本）

使用

<?PHP 
include 'consumer.PHP';

function call_back_func($msg) {
    echo "$msg->payload\n";
}

function handle_error_call_back($msg) {
    echo $msg->errstr();
}

$consumer = New Consumer("localhost:2181");
$consumer->setGroupId("group-test");
$consumer->setTopic("topic-test");
$consumer->setoffsetAutoReset(Consumer::smallest);
$consumer->setErrHandler("handle_error_call_back");

try {
    $consumer->start("echo_message");
}
catch(Exception $e) {
    printf("error: %s\n", $e->getMessage());
}

php-kafka-consumer 依赖使用 官网

https://github.com/meitu/php-kafka-consumer