PHPackages                             micromus/kafka-bus - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. micromus/kafka-bus

ActiveLibrary[Utility & Helpers](/categories/utility)

micromus/kafka-bus
==================

This is my package kafka-bus

v1.1.1(4w ago)01.1k6MITPHPPHP ^8.2CI passing

Since Sep 30Pushed 1mo ago1 watchersCompare

[ Source](https://github.com/micromus/kafka-bus)[ Packagist](https://packagist.org/packages/micromus/kafka-bus)[ Docs](https://github.com/micromus/kafka-bus)[ GitHub Sponsors](https://github.com/Micromus)[ RSS](/packages/micromus-kafka-bus/feed)WikiDiscussions 1.x Synced 3w ago

READMEChangelog (10)Dependencies (12)Versions (48)Used By (6)

Kafka Bus for PHP
=================

[](#kafka-bus-for-php)

[![Latest Version on Packagist](https://camo.githubusercontent.com/ad6f6750d21c5684ed640a17d88e40c14a7d75ada8bc66dee6bc7203ebe527aa/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f762f6d6963726f6d75732f6b61666b612d6275732e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/micromus/kafka-bus)[![GitHub Tests Action Status](https://camo.githubusercontent.com/9b765c154934fdce54c87e2aadbe1c527fb374f250b8b2c633b7106335f28313/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f616374696f6e732f776f726b666c6f772f7374617475732f6d6963726f6d75732f6b61666b612d6275732f72756e2d74657374732e796d6c3f6272616e63683d312e78266c6162656c3d7465737473267374796c653d666c61742d737175617265)](https://github.com/micromus/kafka-bus/actions?query=workflow%3Arun-tests+branch%3A1.x)[![GitHub Code Style](https://camo.githubusercontent.com/a11fb804dbd4983589708fb21a60938f928ca87daf0cde8eda7bdcfe789e7d70/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f616374696f6e732f776f726b666c6f772f7374617475732f6d6963726f6d75732f6b61666b612d6275732f7068702d636f64652d7374796c652e796d6c3f6272616e63683d312e78266c6162656c3d636f64652d7374796c65267374796c653d666c61742d737175617265)](https://github.com/micromus/kafka-bus/actions?query=workflow%3Acode-style+branch%3A1.x)[![GitHub PHPStan](https://camo.githubusercontent.com/500221057232f65927ab01b0371660baa1f4961fba3d77a2add65a352a7b82af/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f616374696f6e732f776f726b666c6f772f7374617475732f6d6963726f6d75732f6b61666b612d6275732f7068707374616e2e796d6c3f6272616e63683d312e78266c6162656c3d7068707374616e267374796c653d666c61742d737175617265)](https://github.com/micromus/kafka-bus/actions?query=workflow%3Aphpstan+branch%3A1.x)[![Total Downloads](https://camo.githubusercontent.com/f85df9c6b94dd4d63f2bd4719a09264d5a3c900de92d629aa670c5ee4c73f3f3/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64742f6d6963726f6d75732f6b61666b612d6275732e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/micromus/kafka-bus)

This is where your description should go. Limit it to a paragraph or two. Consider adding a small example.

Installation
------------

[](#installation)

You can install the package via composer:

```
composer require micromus/kafka-bus
```

### Requirements

[](#requirements)

- PHP ^8.2
- `ext-rdkafka` and a running Kafka cluster
- Optional for consumers: `ext-pcntl` (to handle stop signals gracefully)

Usage (via Composer)
--------------------

[](#usage-via-composer)

### Quick start: Bus with producer and consumer

[](#quick-start-bus-with-producer-and-consumer)

Below is a minimal example of wiring the bus, registering a topic, adding a producer route, and running a listener that handles messages from the same topic.

```