longlang/phpkafka

简介

PHP Kafka 客户端，支持 PHP-FPM、Swoole 环境使用。

通讯协议的结构基于 Java 版本中的 JSON 文件生成，这可能是有史以来支持消息类型最多的 PHP Kafka 客户端，支持全部 50 个 API。

目前已实现消息的生成及消费，本组件仍处于开发及测试阶段。

功能特性

• 支持全部 50 个 API
• 消息压缩支持 (gzip、snappy、lz4、zstd)
• PHP-FPM、Swoole 智能环境识别兼容
• 生产者类
• 消费者类
• SSL 加密通信
• SASL 鉴权
• 更多功能的封装及测试用例编写

环境要求

• PHP >= 7.1
• Kafka >= 1.0.0
• Swoole >= 4.5 (可选)

安装

composer require longlang/phpkafka

文档及示例

• 生产者

• 消费者

示例代码请参考 examples 目录