<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                企業??AI智能體構建引擎,智能編排和調試,一鍵部署,支持知識庫和私有化部署方案 廣告
                kafka擴展安裝好后就可以編程測試了,以下代碼是在thinkphp5上實現的。 測試kafka生產者 - ~~~ //測試kafka生產者 public function testProducer() { $broker_list = '127.0.0.1:9092'; $topic = 'test'; $partition = 0; $rk = new \RdKafka\Producer(); $rk->setLogLevel(LOG_DEBUG); $rk->addBrokers($broker_list); $topic = $rk->newTopic($topic); $message = 'this is a php test'; $topic->produce(RD_KAFKA_PARTITION_UA,$partition,json_encode($message)); } ~~~ 測試kafka消費者 - ~~~ //測試kafka消費者 public function testConsumer($object,$callback) { $broker_list = '127.0.0.1:9092'; $topic = 'test'; $conf = new \RdKafka\Conf(); $conf->set('group.id',0); $conf->set('metadata.broker.list',$broker_list); $topicConf = new \RdKafka\TopicConf(); $topicConf->set('auto.offset.reset','smallest'); $conf->setDefaultTopicConf($topicConf); $consumer = new \RdKafka\KafkaConsumer($conf); $consumer->subscribe([$topic]); echo 'waiting message....'; while (true){ $message = $consumer->consume(120*1000); switch ($message->err){ case RD_KAFKA_RESP_ERR_NO_ERROR: echo 'msg payload....'; $object->$callback($message->payload); break; } sleep(1); } } ~~~
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看