zhizhong/kafka

此包的最新版本（dev-master）没有提供许可证信息。

帮助在 Laravel 中使用 kafka

维护者

详细信息

github.com/leon19910505/kafka

源代码

问题

安装量: 7,040

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 0

分支: 0

开放问题: 0

dev-master 2019-06-26 07:28 UTC

Unknown License 15ac06f5b83451781c8ea2acf0cafa45f26cb9f6

  • leon <303603174.woop@qq.com>

This package is not auto-updated.

Last update: 2024-09-27 08:54:12 UTC

README

composer require zhizhong/kafka:dev-master

配置

在您的环境中设置 kafka 代理路由，它可以是一个字符串列表

KAFKA_BROKERS=127.0.0.1:2086,127.0.0.2:2086

用法

生产者

生产消息的最简单方法是使用帮助函数 kafka_dispatch

kafka_dispatch($topic, $msg)

注意： $msg 必须是一个数组

消费者

$consumer = new Consumer($topic);
while (true) {
    $msg = $consumer->consume();
    print_r($msg);
}