/kafka-sample-php

百度消息服务PHP样例

Primary LanguagePHPMIT LicenseMIT

百度消息服务PHP样例

百度消息服务是分布式、高可扩展、高通量的托管消息队列服务。完全兼容开源Kafka。本样例展示如何使用php-rdkafka客户端访问百度消息服务。

环境要求

准备工作

准备工作的细节请参考BCE官网帮助文档

  1. 在管理控制台中创建好主题，并获取主题名称topic_name。
  2. 在管理控制台中下载您的kafka-key.zip，包含PHP程序使用的client.pem，client.key，ca.pem。
  3. 用上一步的文件替换样例代码中的client.pem、client.key以及ca.pem。

运行样例代码

安装php-rdkafka

sh setup-librdkafka.sh
pecl install rdkafka
echo "extension=rdkafka.so" >> /etc/php.ini

运行样例代码

php consumer.php --topic=topic_name

php producer.php --topic=topic_name

参考链接