189 8069 5689

php测试kafka项目示例分析

今天就跟大家聊聊有关php测试kafka项目示例分析,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

专注于为中小企业提供做网站、成都做网站服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业淇滨免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了千余家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。

概述

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

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

安装kafka-php项目依赖

composer require nmred/kafka-php

produce.php

setMetadataRefreshIntervalMs(10000);$config->setMetadataBrokerList('127.0.0.1:9092');$config->setBrokerVersion('0.10.2.1');$config->setRequiredAck(1);$config->setIsAsyn(false);$config->setProduceInterval(500);$producer = new \Kafka\Producer(function() { $t = time(); return array( array(  'topic' => 'test',  'value' => $t,  'key' => $t, ), );});$producer->success(function($result) { var_export($result);});$producer->error(function($errorCode) { var_dump('error', $errorCode);});$producer->send();

consumer.php

setMetadataRefreshIntervalMs(10000);$config->setMetadataBrokerList('127.0.0.1:9092');$config->setGroupId('test');$config->setBrokerVersion('0.10.2.1');$config->setTopics(array('test'));$consumer = new \Kafka\Consumer();$consumer->start(function($topic, $part, $message) { var_dump($message);});

测试生产者

php produce.php

测试消费者

php consumer.php

看完上述内容,你们对php测试kafka项目示例分析有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。


网站题目:php测试kafka项目示例分析
网页URL:http://cdxtjz.cn/article/ipsjig.html

其他资讯