laravel框架中如何使用rdkafka的消费者
1. 运行环境
1). 当前使用的 Laravel 版本?
laravel版本是 Laravel Framework 9.28.0
//: <> (使用 php artisan --version
命令查看)
2). 当前使用的 php/php-fpm 版本?
PHP 版本:
php8.0.2
php-fpm 版本:
3). 当前系统
mac
//: <> (期待数值 Windows 10 / Ubuntu 20.4 / CentOS 8 )
4). 业务环境
5). 相关软件版本
2. 问题描述?
之前一直用golang开发,消费kafka的时候,可以直接启用一个goroutine消费即可,但是php没有goroutine,那我应该怎么消费消息那?是放在一个cron任务里么?比如我的的cron任务每一分钟执行一次,然后在cron任务里消费kafka的数据。
那如果cron任务一分钟没有把kafka里面的数据消费完,会有什么影响么?
www.cnblogs.com/jzxy/articles/1345...
博客:laravel,Lumen 使用Kafka队列
用 laravel 的队列处理,然后队列驱动换成 kafka。得先装 kafka 队列驱动相关 composer 包
supervisor
进行守护,根据需要配置消费进程数量注意点
:消息消费的幂等性, 时效性,可靠性以及消费重试,错误处理等消息体的包装:唯一ID,事件类型,生产创建时间等