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. micromus/kafka-bus

ActiveLibrary

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

This is my package kafka-bus

v0.6.8(1y ago)0650[1 PRs](https://github.com/micromus/kafka-bus/pulls)5MITPHPPHP ^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 1mo ago

READMEChangelog (10)Dependencies (8)Versions (31)Used By (5)

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/d80467236ed2a0547f68281d3a50be91525dbea0b6a4208d7b30941a05844e5e/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f616374696f6e732f776f726b666c6f772f7374617475732f6d6963726f6d75732f6b61666b612d6275732f72756e2d74657374732e796d6c3f6272616e63683d6d61696e266c6162656c3d7465737473267374796c653d666c61742d737175617265)](https://github.com/micromus/kafka-bus/actions?query=workflow%3Arun-tests+branch%3Amain)[![GitHub Code Style](https://camo.githubusercontent.com/9ef6515f38d3451a355a3b5e30c777924d814e62d4b7e9d4898875e44832b2ba/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f616374696f6e732f776f726b666c6f772f7374617475732f6d6963726f6d75732f6b61666b612d6275732f7068702d636f64652d7374796c652e796d6c3f6272616e63683d6d61696e266c6162656c3d636f64652532307374796c65267374796c653d666c61742d737175617265)](https://github.com/micromus/kafka-bus/actions?query=workflow%3A%22PHP+Code+Style%22+branch%3Amain)[![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.

```