成人性色生活片免费看,av人摸人人人澡人人超碰小说,成人无码精品一区二区三区

首頁(yè)

PHP 函式庫(kù)

其它類別庫(kù)

PHP-kafka客戶端程式庫(kù)(PECL)

其它類別庫(kù)

立即獲取

PHP-kafka客戶端程式庫(kù)(PECL)

Kafka是一種高吞吐量的分散式發(fā)布訂閱訊息系統(tǒng)，它可以處理消費(fèi)者規(guī)模的網(wǎng)站中的所有動(dòng)作流程資料。這種動(dòng)作（網(wǎng)頁(yè)瀏覽，搜尋和其他使用者的行動(dòng)）是在現(xiàn)代網(wǎng)路上的許多社會(huì)功能的關(guān)鍵因素。這些資料通常是由於吞吐量的要求而透過(guò)處理日誌和日誌聚合來(lái)解決。對(duì)於像Hadoop的一樣的日誌資料和離線分析系統(tǒng)，但又要求即時(shí)處理的限制，這是一個(gè)可行的解決方案。 Kafka的目的是透過(guò)Hadoop的平行載入機(jī)制來(lái)統(tǒng)一線上和離線的訊息處理，也是為了透過(guò)叢集來(lái)提供即時(shí)的消費(fèi)。

<?php
$rk = new RdKafka\Consumer();
$rk->setLogLevel(LOG_DEBUG);
$rk->addBrokers("127.0.0.1");
$topic = $rk->newTopic("test");
$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
while (true) {
    $msg = $topic->consume(0, 1000);
    if ($msg->err) {
        echo $msg->errstr(), "\n";
        break;
    } else {
        echo $msg->payload, "\n";
    }
}

免責(zé)聲明

本站所有資源皆由網(wǎng)友貢獻(xiàn)或各大下載網(wǎng)站轉(zhuǎn)載。請(qǐng)自行檢查軟體的完整性！本站所有資源僅供學(xué)習(xí)參考。請(qǐng)不要將它們用於商業(yè)目的。否則，一切後果都由您負(fù)責(zé)！如有侵權(quán)，請(qǐng)聯(lián)絡(luò)我們刪除。聯(lián)絡(luò)方式：admin@php.cn