高端网站设计公司排行榜,免费发帖平台,网站建设 是否计入固定资产,外贸出口平台网站# 首先在保证php已经正确安装的情况下#xff1a;# 安装jdk(本人安装jdk7) 和 scala 因为kafka基于scala开发# 之后解压安装包 进入 运行命令 ./gradlew jar # 会下载一些包 # 首先运行 zookeeper ./bin/zookeeper-server-start.sh ./config/zookeeper.properties# 之后运行k…# 首先在保证php已经正确安装的情况下# 安装jdk(本人安装jdk7) 和 scala 因为kafka基于scala开发# 之后解压安装包 进入 运行命令 ./gradlew jar # 会下载一些包 # 首先运行 zookeeper ./bin/zookeeper-server-start.sh ./config/zookeeper.properties# 之后运行kafka ./bin/kafka-server-start.sh ./config/server.properties# 接下来安装PHP的kafka扩展# 下载 wget https://github.com/EVODelavega/phpkafka/archive/master.zip# 之后进入文件夹 phpize ./configure --enable-kafka --with-php-config/usr/local/php/bin/php-config make# 出现问题# 解决# 下载 wget https://github.com/edenhill/librdkafka/archive/master.zip# 之后安装# 安装成功之后在重新安装kafka扩展# 如果出现错误 没有config.h.in的提示# 需要用autoheader创建出来php -m | grep kafka# 说明扩展安装成功 # 之后测试# 测试代码在README中$kafka new Kafka(localhost:9092);$kafka-produce(topic_name, message content);//get all the available partitions$partitions $kafka-getPartitionsForTopic(topic_name);//use it to OPTIONALLY specify a partition to consume from//if not, consuming IS slower. To set the partition:$kafka-setPartition($partitions[0]);//set to first partition//then consume, for example, starting with the first offset, consume 20 messages$msg $kafka-consume(topic_name, Kafka::OFFSET_BEGIN, 20);var_dump($msg);//dumps array of messages
