<?php
$rk = new RdKafka\Consumer();
$rk->setLogLevel(LOG_DEBUG);
$rk->addBrokers("10.0.0.246");
$topic = $rk->newTopic("azgar-topic");
$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";
}
}
я пробую приведенный выше код в командной строке, он выдаст вывод, но в выводе браузера не появится класс rdcafka не найден ошибка в файле журнала ошибок