swoole/phpkafka
Stars: 250
Forks: 46
Pull Requests: 36
Issues: 56
Watchers: 10
Last Updated: 2023-08-16 06:58:52
PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.
License: Apache License 2.0
Languages: PHP, Dockerfile, Shell
longlang/phpkafka
Introduction
English | 简体中文
PHP Kafka client is used in PHP-FPM and Swoole.
The communication protocol is based on the JSON file in Java. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.
The produce and the consume of messages are implemented. The component is in developing and testing.
Features
- Support all 50 APIs
- Message compression
- PHP-FPM and Swoole compatible
- Producer
- Consumer
- SASL
- SSL
- More features and test cases
Environment
- PHP >= 7.1
- Kafka >= 1.0.0
- Swoole >= 4.5 (optional)
Installation
composer require longlang/phpkafka
Documentation and Examples
Refer to examples for code examples.
OPEN ISSUES
See all- phpkafka的topic不支持正则？ by @waytoviva
- 配置新起的消费者组配置从头消费还是从最新的消息开始消费 by @djwjiawei
- 不支持一次消费多条消息么 by @xiaobingge
- Support for RedPanda? by @slushpuppy
- minBytes和maxBytes未生效 by @djwjiawei
- 如何设置auto.offset.reset值 by @luxin88
- 设置了exception callback 可能会死循环 by @chunhei2008
- 请教如何投递延迟任务 by @huangdijia
- 在swoole服务中, kafka生产者每过一段时间就报错 by @insomniazz
- Invalid length 352518912 given, it should be lesser than or equals to 5242880 by @avehub
- updateApiVersions 报错 [ERROR] [10753] Unknown[385] by @bearzlh
- 支持设置producer端参数么 by @nazrydirunn
- 当向一个不存在的 topic 生产消息时导致无限循环最后内存溢出 by @18310691938
- Uncaught longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member. by @shuaiki
- Getting SocketException while producing an event to Kafka Topic by @karunk-hq
- 对消费者指定分区没法操作 by @yyforeveryl
- [Warning] [82] The broker rejected this static consumer since another consumer with the same group.instance.id has registered with a different member.id. by @wuxi889