Bibliothèque cliente PHP-kafka (PECL)

Kafka est un système de messagerie de publication-abonnement distribué à haut débit qui peut gérer toutes les données de streaming d'action sur les sites Web grand public. De telles actions (navigation sur le Web, recherches et autres actions des utilisateurs) constituent un facteur clé dans de nombreuses fonctions sociales sur le Web moderne. Ces données sont généralement traitées par le traitement des journaux et l'agrégation des journaux en raison des exigences de débit. Pour les données de journaux et les systèmes d'analyse hors ligne comme Hadoop, mais nécessitant des contraintes de traitement en temps réel, il s'agit d'une solution réalisable. L'objectif de Kafka est d'unifier le traitement des messages en ligne et hors ligne via le mécanisme de chargement parallèle de Hadoop et de fournir une consommation en temps réel via le cluster.

<?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";
    }
}