PHPackages                             cuongdinhngo/lara-kafka - 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. cuongdinhngo/lara-kafka

ActiveLibrary

cuongdinhngo/lara-kafka
=======================

Laravel Kafka

1.1(4y ago)141MITPHPPHP ^7.4

Since Mar 21Pushed 4y ago1 watchersCompare

[ Source](https://github.com/cuongdinhngo/lara-kafka)[ Packagist](https://packagist.org/packages/cuongdinhngo/lara-kafka)[ Docs](https://github.com/cuongdinhngo/lara-kafka)[ RSS](/packages/cuongdinhngo-lara-kafka/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (2)DependenciesVersions (4)Used By (0)

Lara Kafka Client
=================

[](#lara-kafka-client)

Laravel Kafka

1 - Install `cuongdinhngo/lara-kafka` using Composer.

```
$ composer require cuongdinhngo/lara-kafka
```

2 - Add the following service provider in `config/app.php`

```
    /*
     * Package Service Providers...
     */
    LaraAssistant\LaraKafka\LaraKafkaServiceProvider::class,
```

This command copies Libraries/Kafka folder into app that contains KafkaConsumer & KafkaProducer classes

3 - Create a topic

You must start Zookeeper and Kafka service, [please read more detail about how to install kafka](https://www.digitalocean.com/community/tutorials/how-to-install-apache-kafka-on-ubuntu-20-04)

```
~/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic TutorialTopic
```

4 - Create a message

```
use App\Libraries\Kafka\KafkaProducer;
use App\Libraries\Kafka\KafkaConsumer;

. . .

   public function testKafka()
   {
       dump(date('Y/m/d h:i:s', time()));
       $kafkProducer = new KafkaProducer("TutorialTopic");
       $kafkProducer->setBrokers("localhost:9092");
       $kafkProducer->init();
       $kafkProducer->addPayload("HELLO ... ".date('Y/m/d h:i:s', time()));
       dd(__METHOD__);
   }
```

Please member that message content must be string

5 - Consume a message

```
   public function consumeKafka()
   {
       dump('start ...');
       dump(date('Y/m/d h:i:s', time()));

       $consumer = new KafkaConsumer();
       $consumer->init(
           ['TutorialTopic'],
           'myConsumerGroup',
           'localhost:9092',
           [
               'group.id' => 'myConsumerGroup',
               'auto.offset.reset' => 'earliest'
           ]
       );

       echo "Waiting for partition assignment... (make take some time when\n";
       echo "quickly re-joining the group after leaving it.)\n";

       $consumer->consume();

   }
```

You can modify Libraries/Kafka/KafkaConsumer class to handle message and error

```
   protected function handleMessage($message)
   {
       dump($message);
   }

   protected function handleErrors($message)
   {
       switch ($message->err) {
           case RD_KAFKA_RESP_ERR__PARTITION_EOF:
               dump("No more messages; will wait for more");
               break;
           case RD_KAFKA_RESP_ERR__TIMED_OUT:
               dump('Timed out: '.date('Y/m/d h:i:s', time()));
               break;
           default:
               throw new \Exception($message->errstr(), $message->err);
               break;
       }
   }
```

###  Health Score

23

—

LowBetter than 27% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity6

Limited adoption so far

Community8

Small or concentrated contributor base

Maturity51

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

Total

2

Last Release

1513d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/8dfc050aef777dd165bc3f60e724e4b53471854fcb3b522c103c936bd56e6643?d=identicon)[ngodinhcuong](/maintainers/ngodinhcuong)

---

Top Contributors

[![cuongdinhngo](https://avatars.githubusercontent.com/u/55419546?v=4)](https://github.com/cuongdinhngo "cuongdinhngo (5 commits)")

---

Tags

laravelconsumerkafkamessage-brokerproducer

### Embed Badge

![Health badge](/badges/cuongdinhngo-lara-kafka/health.svg)

```
[![Health](https://phpackages.com/badges/cuongdinhngo-lara-kafka/health.svg)](https://phpackages.com/packages/cuongdinhngo-lara-kafka)
```

###  Alternatives

[php-kafka/php-simple-kafka-lib

PHP Simple Kafka library

1045.7k](/packages/php-kafka-php-simple-kafka-lib)[iamfarhad/laravel-rabbitmq

A robust RabbitMQ driver for Laravel Queue with advanced message queuing, reliable delivery, and high-performance async processing capabilities

3215.6k](/packages/iamfarhad-laravel-rabbitmq)[hhxsv5/laravel-kafka-logger

The Kafka logger for Laravel.

1014.3k](/packages/hhxsv5-laravel-kafka-logger)

PHPackages © 2026

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