在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
<?php $conf = new \RdKafka\Conf(); //捕获错误的回调 $conf->setErrorCb(function ($kafka, $err, $reason) { \Log::error('kafkaError', ['errorStr' => rd_kafka_err2str($err), 'err' => $err, 'reason' => $reason, 'content' => $kafka]); }); $rk = new \RdKafka\Producer($conf); $rk->setLogLevel(LOG_DEBUG); $rk->addBrokers($this->url); $topic = $rk->newTopic($this->topic); //写kafka $topic->produce(RD_KAFKA_PARTITION_UA, 0, $str); $rk->poll(0);
|
2022-08-17
2022-11-06
2022-07-18
2022-08-18
2022-07-29
请发表评论