<?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类未找到错误出现在错误日志文件中
暂无答案!
目前还没有任何答案,快来回答吧!