PHPackages                             michaeldouglas/debeziumstream - 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. [Database & ORM](/categories/database)
4. /
5. michaeldouglas/debeziumstream

ActiveLibrary[Database & ORM](/categories/database)

michaeldouglas/debeziumstream
=============================

A client library to work with debezium and apache kafka for Database stream.

0.06(7y ago)753mitPHPPHP >=5.6

Since Aug 23Pushed 7y ago1 watchersCompare

[ Source](https://github.com/michael158/laravel-debeziumstream)[ Packagist](https://packagist.org/packages/michaeldouglas/debeziumstream)[ RSS](/packages/michaeldouglas-debeziumstream/feed)WikiDiscussions master Synced 3d ago

READMEChangelog (7)DependenciesVersions (8)Used By (0)

Laravel Debezium Stream Consumer
================================

[](#laravel-debezium-stream-consumer)

### Requirements

[](#requirements)

1. Guzzle HTTP
2. Laravel 5.2+

### Install Library

[](#install-library)

in folder of project run:

```
$ composer require michaeldouglas/debeziumstream

```

### Configure Apache KAFKA and DEBEZIUM

[](#configure-apache-kafka-and-debezium)

Insert into .env file the folowers config lke example:

```
KAFKA_HOST=18.231.179.169
KAFKA_PORT=9092
KAFKA_CONNECT_HOST=18.231.179.169:8083"
KAFKA_CONSUMER_BINARY="kafka-console-consumer"
KAFKA_CONSUMER_BINARY_PATH=/usr/local/etc/confluent/bin

DEBEZIUM_DB_CONNECTOR=mysql
DEBEZIUM_DB_CONNECTOR_NAME=otrs3-connector
DEBEZIUM_DB_HOST=127.0.0.1
DEBEZIUM_DB_DATABASE=otrs5
DEBEZIUM_DB_SERVER_ID=1
DEBEZIUM_DB_SERVER_NAME=localdb
DEBEZIUM_DB_USER=root
DEBEZIUM_DB_PASSWORD=

```

### Configure Service Provider

[](#configure-service-provider)

In file config\\app.php inside providers put the code:

```
 MichaelDouglas\DebeziumStream\Providers\DebeziumKafkaServiceProvider::class

```

### Publish config files

[](#publish-config-files)

```
$ php artisan vendor:publish

```

### Configure class to receive KAFKA EVENTS

[](#configure-class-to-receive-kafka-events)

In file config\\kafka.php

```
 /*
    |--------------------------------------------------------------------------
    | Handle Class
    |--------------------------------------------------------------------------
    | The class who will receive Kafka Topic Messages
    */
    'handler_class' => 'your class here',

    /*
    |--------------------------------------------------------------------------
    | Handle Methods
    |--------------------------------------------------------------------------
    | The class methods who will receiver Kafka Events
    */
    'event_methods' => [
       'create' => 'your method here',
       'update' => 'your method here',
       'delete' => 'your method here'
    ]

```

The params look like this example:

```
class TestService
{

    public function create($after, $topic)
    {

    }

    public function update($before, $after, $topic)
    {

    }

    public function delete($before, $topic)
    {

    }

}

```

### Init Kafka Consumer Work

[](#init-kafka-consumer-work)

```
$ php artisan kafka:listen --topic=topic_name

```

laravel-debeziumstream
======================

[](#laravel-debeziumstream)

###  Health Score

26

—

LowBetter than 43% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity13

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity52

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~6 days

Total

7

Last Release

2787d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/9007479?v=4)[Michael Douglas](/maintainers/michael158)[@michael158](https://github.com/michael158)

---

Top Contributors

[![michael158](https://avatars.githubusercontent.com/u/9007479?v=4)](https://github.com/michael158 "michael158 (13 commits)")

---

Tags

consumerkafkaDouglasdebeziummichael

### Embed Badge

![Health badge](/badges/michaeldouglas-debeziumstream/health.svg)

```
[![Health](https://phpackages.com/badges/michaeldouglas-debeziumstream/health.svg)](https://phpackages.com/packages/michaeldouglas-debeziumstream)
```

###  Alternatives

[doctrine/orm

Object-Relational-Mapper for PHP

10.2k285.3M6.2k](/packages/doctrine-orm)[jdorn/sql-formatter

a PHP SQL highlighting library

3.9k115.1M102](/packages/jdorn-sql-formatter)[illuminate/database

The Illuminate Database package.

2.8k52.4M9.4k](/packages/illuminate-database)[mongodb/mongodb

MongoDB driver library

1.6k64.0M546](/packages/mongodb-mongodb)[reliese/laravel

Reliese Components for Laravel Framework code generation.

1.7k3.4M16](/packages/reliese-laravel)[wildside/userstamps

Laravel Userstamps provides an Eloquent trait which automatically maintains `created\_by` and `updated\_by` columns on your model, populated by the currently authenticated user in your application.

7511.7M13](/packages/wildside-userstamps)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)