linux下php擴展kafka的實例分享

wget?https://github.com/edenhill/librdkafka/archive/master.zip?#下載  mv?master.zip?librdkafka-master.zip?#修改包名  unzip?librdkafka-master.zip?#解壓  cd?librdkafka-master?#進入安裝文件夾  ./configure?#配置  make?#編譯  make?install?#安裝

cd?/usr/local/src?#進入安裝包存放目錄  wget?https://github.com/EVODelavega/phpkafka/archive/master.zip?#下載  mv?master.zip?phpkafka-master.zip?#修改包名  unzip?phpkafka-master.zip?#解壓  cd?phpkafka-master?#進入安裝文件夾  /usr/local/php/bin/phpize?#加載php擴展模塊  ./configure?--enable-kafka?--with-php-config=/usr/local/php/bin/php-config?#配置  make?#編譯  make?install?#安裝  3、修改php配置文件  vi?/usr/local/php/etc/php.ini

extension="kafka.so"

<?php phpinfo();  ?>

$kafka?=?new?Kafka("localhost:9092");  $partitions?=?$kafka->getPartitionsForTopic('testkk');  $in?=?fopen('php://stdin',?'r');  while?(true)?{  ????echo?"nEnter?comma?separated?messages:n";  ????$messages?=?explode(',',?fgets($in));  ????foreach?(array_keys($messages)?as?$k)?{  ????????//$messages[$k]?=?trim($messages[$k]);  ????}  ????????$bytes=$kafka->produce("testkk",?"kkkkkkk");  ????printf("nSuccessfully?sent?%d?messages?(%d?bytes)nn",?count($messages),?$bytes);  }