php測試kafka項(xiàng)目示例分析

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

概述

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

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

安裝kafka-php項(xiàng)目依賴

composer require nmred/kafka-php

produce.php

<?phprequire './vendor/autoload.php';date_default_timezone_set('PRC');$config = \Kafka\ProducerConfig::getInstance();$config->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

<?phprequire './vendor/autoload.php';date_default_timezone_set('PRC');$config = \Kafka\ConsumerConfig::getInstance();$config->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

測試消費(fèi)者

php consumer.php

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