一、准备工作

虽然 Kafka 是用 Java/Scala 语言编写的,但这不妨碍它对多语言的支持。

可以在 Kafka 官网的查看 Kafka 支持的语言,其中包括 C/C++、Python、Go 等语言。

PHP 操作 Kafka 需要安装 librdkafka 库和 kafka 的 PHP 扩展。

1.安装 librdkafka 库

2.安装 php-kafka 扩展


二、代码实现

demo 来源于 https://github.com/arnaud-lb/ph


正常的生产逻辑如下:

1.配置生产者客户端参数及创建相应的生产者实例;

2.构建主题;

3.发送消息;

4.关闭生产者实例。

检验消息是否发送成功

终端开启一个消费者:

在另一个窗口执行 php producer.php

可看到消费者终端接收到消息。

完整代码如下: