bjyyb/hyperf-kafka

移植hyperf官方kafka组件的beta版，修复一些问题

dev-main 2021-01-25 10:58 UTC

Requires

• php: >=7.2
• hyperf/pool: ~2.1.0
• hyperf/process: ~2.1.0
• hyperf/utils: ~2.1.0
• longlang/phpkafka: ^1.1
• psr/container: ^1.0
• psr/log: ^1.0

MIT

• php
• kafka
• hyperf

README

安装

composer require bjyyb/hyperf-kafka:dev-main

使用

创建一个消费者

php bin/hyperf.php gen:kafka-consumer Test

• topic 主题
• groupId 分组
• nums 进程数
• autoCommit 自动提交
• enable 是否开启
• $pool 连接池

Hyperf\Kafka\Result::ACK  // 确认
Hyperf\Kafka\Result::DROP // 丢弃不处理
Hyperf\Kafka\Result::REQUEUE // 重新加入队列

创建一个发送者

php bin/hyperf.php gen:kafka-message TestMessage

• $topic 主题
• $value 发送内容
• $key 用于计算发送到那个分区
• $headers 没使用

发送消息

$message = new App\Kafka\Producer\TestMessage('hello kafka');
$producer = make(Hyperf\Kafka\Producer::class);
$producer->send($message);