onemena / laravel-aliyun-kafka
aliyun kafka for laravel5, based on php-rdkafka
0.0.4
2018-05-07 05:29 UTC
Requires
- php: ^7.0
- illuminate/queue: ~5.3|~5.4|~5.5
- illuminate/support: ~5.3|~5.4|~5.5
This package is not auto-updated.
Last update: 2024-04-21 07:49:46 UTC
README
git clone https://github.com/edenhill/librdkafka.git
cd librdkafka && ./configure && make && make install
安装 php-rdkafka
pecl install rdkafka
add extension=rdkafka.so to your php.ini
安装 laravel-aliyun-kafka
composer require onemena/laravel-aliyun-kafka:dev-master
// config/app.php
\LaravelAliYunKafka\LaravelKafkaServiceProvider::class
// config/queue.php
'kafka' => [
'driver' => 'kafka',
'sasl'=>true,
'sasl_plain_username' => env('KAFKA_SASL_PLAIN_USERNAME', 'YOUR AK'), // 阿里云 ak
'sasl_plain_password' => env('KAFKA_SASL_PLAIN_PASSWORD', 'YOUR AC'),,// 阿里云 ac后10位
'bootstrap_servers' => "kafka-ons-internet.aliyun.com:8080", // broker
'ssl.ca.location' => storage_path('config/ca-cert'), // cr 证书 下载 https://help.aliyun.com/document_detail/52376.html
'message.send.max.retries' => 5,
'queue' => env('KAFKA_TOPIC', 'YOUR TOPIC'), // 这里填入你在阿里云控制台配置的topic
'consumer_id' => env('KAFKA_CONSUMER_ID', 'YOU CONSUMER ID'), // 消费者ID,你在阿里云控制台配置的消费之ID
'log_level' => LOG_DEBUG // 日志等级
],
使用方法:
php artisan queue:work kafka --tries=3