今天就跟大家聊聊有關(guān)php測試kafka項目示例分析，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

成都創(chuàng)新互聯(lián)公司是一家專注于成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)與策劃設(shè)計,旌德網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:旌德等地區(qū)。旌德做網(wǎng)站價格咨詢:028-86922220

概述

Kafka是最初由Linkedin公司開發(fā)，是一個分布式、分區(qū)的、多副本的、多訂閱者，基于zookeeper協(xié)調(diào)的分布式日志系統(tǒng)（也可以當做MQ系統(tǒng)），常見可以用于web/nginx日志、訪問日志，消息服務(wù)等等，Linkedin于2010年貢獻給了Apache基金會并成為頂級開源項目。

主要應(yīng)用場景是：日志收集系統(tǒng)和消息系統(tǒng)。

安裝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);});

測試生產(chǎn)者

php produce.php

測試消費者

php consumer.php

看完上述內(nèi)容，你們對php測試kafka項目示例分析有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

分享標題：php測試kafka項目示例分析-創(chuàng)新互聯(lián)
URL分享：http://weahome.cn/article/dhjgje.html