php操作kafka

• php操作kafka----可以參照網上的安裝步驟，先安裝ldkafka rdkafka，然乎啟動zookeeper和kafka服務器

<?php //$conf = new Rdkafka\Producer(); //$producer = new RdKafka\Producer();
class kafka { public $broker_list="localhost:9092"; public $topic = "wuwa"; public $partion = 0; protected $producer = null; protected $consumer = null; public function __construct() { $rk = new RdKafka\Producer(); if(empty($rk)) { throw new \Exception("producer error"); } $rk->setLogLevel(LOG_DEBUG); if(!$rk->addBrokers($this->broker_list)) { throw new \Exception('添加broker失敗'); } $this->producer=$rk; } public function sendmsg($array_message="") { /*$topic = $this->producer->newTopic($this->topic); return $topic->produce(RD_KAFKA_PARTITION_UA,$this->partion,json_encode($array_message));*/
        $topic = $this->producer->newTopic($this->topic); return $topic->produce(RD_KAFKA_PARTITION_UA,$this->partion,$array_message); } } $kafuka = new Kafka(); $kafuka->sendmsg('general! welcome to distributed world!'); $kafuka->sendmsg('好好學編程，泡昌仔和勁兒弟弟!');

輸出結果

general! welcome to distributed world!
好好學編程，泡昌仔和勁兒弟弟!