buqiu/kafka

Kafka distributed publish subscribe message system extension package.

Maintainers

Details

github.com/buqiu/laravel-kafka

Source

Issues

Installs: 2 015

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 1

Forks: 0

Open Issues: 0

v2.1.0 2023-09-14 05:36 UTC

Requires

MIT c38140c2eb8a818d2f18890bd7841c17a93d6361

  • 董坤鸿 <249529979.woop@qq.com>

laravelkafkabuqiu

This package is auto-updated.

Last update: 2025-03-14 09:12:42 UTC

README

介绍

Kafka 分布式发布订阅消息系统扩展包。

环境

php >= 8.1
composer >= 2.0

扩展

RdKafka 自行安装php扩展

使用

1.安装

composer require buqiu/kafka

2.发布 kafka.php 配置文件

php artisan vendor:publish --tag=buqiu-kafka-config

3.修改 config/queue.php 文件，在 connections 数组中追加 kafka 配置信息

'kafka' => [
            'driver' => 'kafka',
            'queue' => env('KAFKA_TOPIC'),
        ],

4.配置 .env 文件

KAFKA_BROKERS=服务地址
KAFKA_SECURITY_PROTOCOL=SASL_SSL
KAFKA_SASL_MECHANISMS=PLAIN
KAFKA_SASL_USERNAME=用户名
KAFKA_SASL_PASSWORD=密码
KAFKA_DEBUG=false
KAFKA_TOPIC=自定义的 Topic
KAFKA_CONSUMER_GROUP_ID=自定义的 Group ID

5.启动 kafka 队列监听

php artisan queue:work kafka

6.代码示例

6.1 修改 .env 文件设置默认队列连接

.env

QUEUE_CONNECTION=kafka

php 代码中使用

KafkaJob::dispatch()->onQueue('default');

6.2 不修改 .env 默认队列连接，手动指定连接

方式一：调用处动态指定

KafkaJob::dispatch()->onQueue('default')->onConnection('kafka');

方式二、KafkaJob 中指定连接属性（推荐）

public function __construct()
{
    $this->onConnection('kafka');
}