php操作kafka

• php操作kafka----可以参照网上的安装步骤，先安装ldkafka rdkafka，然乎启动zookeeper和kafka服务器

<?php
//$conf = new RdkafkaProducer();
//$producer = new RdKafkaProducer();
class kafka
{
    public $broker_list="localhost:9092";
    public $topic = "wuwa";
    public $partion = 0;
    protected $producer = null;
    protected $consumer = null;
    public function __construct()
    {
        $rk = new RdKafkaProducer();
        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!
好好学编程，泡昌仔和劲儿弟弟!