Download the PHP package simpod/kafka-bundle without Composer
On this page you can find all versions of the php package simpod/kafka-bundle. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Informations about the package kafka-bundle
PHP Kafka Symfony bundle for php-rdkafka
Installation
Add as Composer dependency:
Then add KafkaBundle
to Symfony's bundles.php
:
Usage
This package simply makes it easier to integrate https://github.com/arnaud-lb/php-rdkafka with Symfony. For more details how to work with Kafka in PHP, refer to its documentation.
Available console commands:
bin/console debug:kafka:consumers
to list all available consumer groupsbin/console kafka:consumer:run <consumer name>
to run consumer instance
Config:
You can create eg. kafka.yaml
file in your config directory with following content:
authentication
reads env varKAFKA_AUTHENTICATIOn
that contains authentication uri (sasl-plain://user:password
, or it might be just empty indicating no authentication).bootstrap_servers
reads env varKAFKA_BOOTSTRAP_SERVERS
that contains comma-separated list of bootstrap servers (broker-1.kafka:9092,broker-2.kafka:9092
).
If bootstrap_servers
isn't set, it defaults to 127.0.0.1:9092
Services
Following services are registered in container and can be DI injected.
Configuration
class: \SimPod\KafkaBundle\Kafka\Configuration
Configuration service allows easy access to all the configuration properties.
Consuming
There's interface NamedConsumer
available. When your consumer implements it, this bundle autoregisters it.
This is example of simple consumer, it can be then run via bin/console kafka:consumer:run consumer1
Development
There is kwn/php-rdkafka-stubs
listed as a dev dependency so it properly integrates php-rdkafka extension with IDE.
All versions of kafka-bundle with dependencies
simpod/kafka Version ^0.2.0
symfony/config Version ^6.4 || ^7.0
symfony/console Version ^6.4 || ^7.0
symfony/contracts Version ^3.0
symfony/dependency-injection Version ^6.4 || ^7.0
symfony/framework-bundle Version ^6.4 || ^7.0
thecodingmachine/safe Version ^2