php测试kafka项目示例

本文实例讲述了php测试kafka项目。分享给大家供大家参考，具体如下：

概述

kafka是最初由linkedin公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式日志系统（也可以当做mq系统），常见可以用于web/nginx日志、访问日志，消息服务等等，linkedin于2010年贡献给了apache基金会并成为顶级开源项目。

主要应用场景是：日志收集系统和消息系统。

安装kafka-php项目依赖

compor require nmred/kafka-php

produce.php

<?phprequire '关心是什么意思./vendor/autoload.php';date_default_timezone_t('prc');$config = \kafka\producerconfig::getinstance();$config->tmetadatarefreshintervalms(10000);$config->tmetadatabrokerlist('127.0.0.1:9092');$config->tbrokerversion('0.10.2.1');$config->trequiredack(1);$config->tisasyn(fal);$config->tproduceinterval(500);$producer = new \kafka\produc我心爱的文具盒er(function() { $t = time(); return array( array(  'topic' => 'test',  'value' => $t,  'key' => $t, ), );});$pro中小学学籍网ducer->success(function($result) { var_export($result);});$producer->error(functi少年黄大年观后感on($errorcode) { var_dump('error', $errorcode);});$producer->nd();

consumer.php

<?phprequire './vendor/autoload.php';date_default_timezone_t('prc');$config = \kafka\consumerconfig::getinstance();$config->tmetadatarefreshintervalms(10000);$config->tmetadatabrokerlist('127.0.0.1:9092');$config->tgroupid('test');$config->tbrokerversion('0.10.2.1');$config->ttopics(array('test'))科德学院;$consumer = new \kafka\consumer();$consumer->start(function($topic, $part, $message) { var_dump($message);});

测试生产者

php produce.php

测试消费者

php consumer.php