메시징에 PHP 및 Kafka를 사용하는 방법 알아보기

sudo apt-get install php-zmq librdkafka-dev

sudo pecl install zmq-beta

<?php

$conf = new RdKafkaConf();
$conf->set('metadata.broker.list', 'localhost:9092');

$producer = new RdKafkaProducer($conf);

$topic = $producer->newTopic("test");

for ($i = 0; $i < 10; $i++) {
    $message = "Message " . $i;
    $topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);
}

$producer->flush(10000);

$consumerConf = new RdKafkaConf();
$consumerConf->set('metadata.broker.list', 'localhost:9092');
$consumerConf->set('group.id', 'testgroup');

$consumer = new RdKafkaKafkaConsumer($consumerConf);
$consumer->subscribe(['test']);

while (true) {
    $message = $consumer->consume(120 * 1000);

    switch ($message->err) {
        case RD_KAFKA_RESP_ERR_NO_ERROR:
            echo "Received message: " . $message->payload . "
";
            break;
        case RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo "End of partition
";
            break;
        case RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo "Timed out
";
            break;
        default:
            echo "Error: " . $message->errstr() . "
";
            break;
    }

    $consumer->commit();
}