Low level consumer example

This example shows how to use the low level consumer.

Example #1 Low-level consumer example

<?php

$conf 
= new RdKafka\Conf();

// Set the group id. This is required when storing offsets on the broker
$conf->set('group.id''myConsumerGroup');

$rk = new RdKafka\Consumer($conf);
$rk->addBrokers("127.0.0.1");

$topicConf = new RdKafka\TopicConf();
$topicConf->set('auto.commit.interval.ms'100);

// Set the offset store method to 'file'
$topicConf->set('offset.store.method''broker');

// Alternatively, set the offset store method to 'none'
// $topicConf->set('offset.store.method', 'none');

// Set where to start consuming messages when there is no initial offset in
// offset store or the desired offset is out of range.
// 'smallest': start from the beginning
$topicConf->set('auto.offset.reset''smallest');

$topic $rk->newTopic("test"$topicConf);

// Start consuming partition 0
$topic->consumeStart(0RD_KAFKA_OFFSET_STORED);

while (
true) {
    
$message $topic->consume(0120*10000);
    switch (
$message->err) {
        case 
RD_KAFKA_RESP_ERR_NO_ERROR:
            
var_dump($message);
            break;
        case 
RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo 
"No more messages; will wait for more\n";
            break;
        case 
RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo 
"Timed out\n";
            break;
        default:
            throw new \
Exception($message->errstr(), $message->err);
            break;
    }
}

?>