spsn / kafka
Requires
- php: ^8.2|^8.3
- ext-rdkafka: ^6.0
- mateusjunges/laravel-kafka: ^2.3
- spatie/laravel-data: ^4.11
- dev-master
- 1.3.21
- 1.3.20
- 1.3.19
- 1.3.18
- 1.3.17
- 1.3.16
- 1.3.15
- 1.3.14
- 1.3.13
- 1.3.12
- 1.3.11
- 1.3.10
- 1.3.9
- 1.3.8
- 1.3.7
- 1.3.6
- 1.3.5
- 1.3.4
- 1.3.3
- 1.3.2
- 1.3.1
- 1.3
- 1.2.15
- 1.2.14
- 1.2.13
- 1.2.12
- 1.2.11
- 1.2.10
- 1.2.9
- 1.2.8
- 1.2.7
- 1.2.6
- 1.2.5
- 1.2.4
- 1.2.3
- 1.2.1
- 1.2.0
- 1.1.10
- 1.1.9
- 1.1.8
- 1.1.7
- 1.1.6
- 1.1.5
- 1.1.4
- 1.1.3
- 1.1.2
- 1.1.1
- 1.1.0
- 1.0.26
- 1.0.25
- 1.0.24
- 1.0.23
- 1.0.22
- 1.0.21
- 1.0.20
- 1.0.19
- 1.0.18
- 1.0.17
- 1.0.16
- 1.0.15
- 1.0.14
- 1.0.13
- 1.0.12
- 1.0.11
- 1.0.10
- 1.0.9
- 1.0.8
- 1.0.7
- 1.0.6
- 1.0.5
- 1.0.4
- 1.0.3
- 1.0.2
- 1.0.1
- 1.0.0
- dev-analysis-lZOPGN
This package is auto-updated.
Last update: 2025-02-05 12:13:30 UTC
README
php artisan vendor:publish --tag=spsn-kafka-config
- опубликовать конфиг с настройками, в котором описаны настройки для консьюмера и продьюсера
Данный пакет требует наличия в приложении библиотеки mateusjunges/laravel-kafka
. После её установки нужно прописать команду php artisan vendor:publish --tag=laravel-kafka-config
, чтобы опубликовать конфиг с настройками кафки. В файле config/kafka.php
нужно указать настройки SASL и брокеров
Команды
php artisan spsn-kafka:consumer
- запустить консьюмер топиков. Можно запустить локально и смотреть входящие сообщения. Если приложения запускается в докере, то консьюмер запускается автоматически
php artisan spsn-kafka:make-listener
- создать слушатель события SpsnKafkaMessageReceived
, которое принимает сообщения из топиков. Если слушатель уже создан или описан другой слушатель этого события, то эту команду не обязательно вводить
Общая информация
Всю логику по работе с входящими сообщениями описывать в слушателе SpsnKafkaMessageReceived
Для создания сообщений используетя SpsnKafkaProducer