PHPackages                             faaren-tech/kafka-client - 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. faaren-tech/kafka-client

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

faaren-tech/kafka-client
========================

Simple Kafka Wrapper

0.2.0(4y ago)2206MITPHP

Since Dec 8Pushed 4y agoCompare

[ Source](https://github.com/FAAREN-tech/kafka-client)[ Packagist](https://packagist.org/packages/faaren-tech/kafka-client)[ RSS](/packages/faaren-tech-kafka-client/feed)WikiDiscussions main Synced 1mo ago

READMEChangelog (1)Dependencies (2)Versions (5)Used By (0)

Laravel Kafka Client
====================

[](#laravel-kafka-client)

This package offers a simple Kafka-Client-Wrapper with Laravel Facades and configs

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

[](#installation)

Run the following commands:

```
// Install the package
composer require faaren-tech/kafka-client

// Publish config
php artisan vendor:publish --provider="FaarenTech\KafkaClient\KafkaClientServiceProvider"
```

Configuration Parameter
-----------------------

[](#configuration-parameter)

The parameters are prepared and needs to be added to your .env

```
FAA_KAFKA_REGISTRY_URL=XXXX
FAA_KAFKA_REGISTRY_AUTH_USER=XXXX
FAA_KAFKA_REGISTRY_AUTH_PASSWORD=XXXX

FAA_KAFKA_BROKER_URL=XXXX
FAA_KAFKA_BROKER_AUTH_USER=XXXX
FAA_KAFKA_BROKER_AUTH_PASSWORD=XXXX
FAA_KAFKA_CONSUMER_GROUP_ID=XXXX

```

### Producer

[](#producer)

```
            Producer::topic('TopicName')
                ->buildProducerWithRegistry('BodySchema', 'KeySchema')
                ->message('KeyValue', 'Data2Send', 'headers', 'partition')
                ->produce();
            Producer::flush();
```

### Consumer

[](#consumer)

```
        $consumer = Consumer::topic('TopicName')
            ->buildConsumerWithRegistry('BodySchema', 'KeySchema')
            ->subscribe();

        while(true) {
            /**
              * First Parameter, is the Timeout in ms, Second Parameter is the Auto-Decode Option
            */
            $consumer->consume(5000, false, function($consumer, $message){
                //to "commit" the message, please use the ack method
                $consumer->ack($message);
            });

        }
```

###  Health Score

22

—

LowBetter than 22% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity14

Limited adoption so far

Community2

Small or concentrated contributor base

Maturity43

Maturing project, gaining track record

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 ~21 days

Total

4

Last Release

1552d ago

Major Versions

0.2.0 → 1.0.0-rc.12022-01-25

### Community

Maintainers

![](https://www.gravatar.com/avatar/4288116c61a0cee2d1e7417272fba4c6002a941dc7b645fe366edcbdce56182e?d=identicon)[faaren](/maintainers/faaren)

### Embed Badge

![Health badge](/badges/faaren-tech-kafka-client/health.svg)

```
[![Health](https://phpackages.com/badges/faaren-tech-kafka-client/health.svg)](https://phpackages.com/packages/faaren-tech-kafka-client)
```

###  Alternatives

[sensiolabs/minify-bundle

Assets Minifier (CSS, JS) for Symfony & Minify integration in Asset Mapper

5694.9k1](/packages/sensiolabs-minify-bundle)[sider/phinder

PHP code piece finder

5445.5k](/packages/sider-phinder)

PHPackages © 2026

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