PHPackages                             nirmalsharma/laravel-kafka-consumer - 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. nirmalsharma/laravel-kafka-consumer

ActiveLibrary

nirmalsharma/laravel-kafka-consumer
===================================

0.0.6(3y ago)0114MITPHPPHP >=7.2

Since Dec 7Pushed 3y ago2 watchersCompare

[ Source](https://github.com/nirmalsharmamca/laravel-kafka-consumer)[ Packagist](https://packagist.org/packages/nirmalsharma/laravel-kafka-consumer)[ RSS](/packages/nirmalsharma-laravel-kafka-consumer/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (9)DependenciesVersions (12)Used By (0)

A Lightweight Kafka Producer Warpper for Laravel 6+ and PHP 7.3+
----------------------------------------------------------------

[](#a-lightweight-kafka-producer-warpper-for-laravel-6-and-php-73)

Install Kafka Consumer Warpper

```
  composer require nirmalsharma/laravel-kafka-consumer
```

Examples
--------

[](#examples)

[Laravel 6](examples/laravel-6-example)

Use Kafka in code.
------------------

[](#use-kafka-in-code)

Sample code for console

```
namespace App\Console\Commands;

use App\Handlers\TestHandler;
use Illuminate\Console\Command;
use KafkaConsumer;

class TestTopicConsumer extends Command
{
    protected $signature = 'kafka-consume {--partition=} {--consumer-group=} {--topic=}';

    protected $description = 'Kafka consumer!!';

    public function handle(): void
    {
      KafkaConsumer::createConsumer(new TestHandler);
    }

    public function setKafkaConfig(){
        $partition = $this->option('partition');
        if( $partition != null){
            config([
                "kafka.partition" => $partition
            ]);
        }

        $consumer_group_id = $this->option('consumer-group');
        if( !empty($consumer_group_id)){
            config([
                "kafka.consumer_group_id" => $consumer_group_id
            ]);
        }

        $topic = $this->option('topic');
        if( !empty($topic)){
            config([
                "kafka.topic" => $topic
            ]);
        }

    }
}

TestHandler.php
-----------------

namespace App\Handlers;

use Illuminate\Support\Facades\Log;

class TestHandler
{
  public function __invoke( $message)
  {
    print_r([$message]);
    Log::debug('Message received!', [
        $message
    ]);
  }
}
```

To start listening messages by run following command:
-----------------------------------------------------

[](#to-start-listening-messages-by-run-following-command)

```
  php artisan kafka-consume {--partition=} {--consumer-group=} {--topic=}

```

You can check handler log message in "storage/logs/laravel.log" file or run the following command in your terminal:
-------------------------------------------------------------------------------------------------------------------

[](#you-can-check-handler-log-message-in-storagelogslaravellog-file-or-run-the-following-command-in-your-terminal)

```
  tail -f storage/logs/laravel.log

```

Environment Variables
---------------------

[](#environment-variables)

To run this, you will need to add the following environment variables to your .env file Config reference:

```
IS_KAFKA_ENABLED=             // Default:  1
KAFKA_BROKERS=
KAFKA_DEBUG=                  // Default: false
KAFKA_SSL_PROTOCOL=           // Default: plaintext or ssl for consumer
KAFKA_COMPRESSION_TYPE=       // Default: none
KAFKA_IDEMPOTENCE=            // Default: false
KAFKA_CONSUMER_GROUP_ID=      // Default: group
KAFKA_OFFSET_RESET=           // Default: latest
KAFKA_AUTO_COMMIT=            // Default: true
KAFKA_ERROR_SLEEP=            // Default: 5
KAFKA_PARTITION=              // Default: 0
KAFKA_TOPIC=                  //

```

Authors
-------

[](#authors)

- [Nirmal Sharma](https://github.com/nirmalsharmamca)
- [Praveen Menezes](https://github.com/praveenmenezes)

License
-------

[](#license)

[MIT](https://choosealicense.com/licenses/mit/)

Features
--------

[](#features)

- Light weight kakfa wrapper
- Easy to use event produce in code.

###  Health Score

21

—

LowBetter than 19% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity10

Limited adoption so far

Community11

Small or concentrated contributor base

Maturity37

Early-stage or recently created project

 Bus Factor1

Top contributor holds 73.7% 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 ~2 days

Total

10

Last Release

1237d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/b73872f148a595a3893c4f43684add3758f50e16408167d98876c4ab9714610e?d=identicon)[nirmalsharmamca](/maintainers/nirmalsharmamca)

---

Top Contributors

[![nirmalkissht](https://avatars.githubusercontent.com/u/118504956?v=4)](https://github.com/nirmalkissht "nirmalkissht (14 commits)")[![praveen-kissht](https://avatars.githubusercontent.com/u/156430945?v=4)](https://github.com/praveen-kissht "praveen-kissht (4 commits)")[![nirmalsharmamca](https://avatars.githubusercontent.com/u/13479422?v=4)](https://github.com/nirmalsharmamca "nirmalsharmamca (1 commits)")

### Embed Badge

![Health badge](/badges/nirmalsharma-laravel-kafka-consumer/health.svg)

```
[![Health](https://phpackages.com/badges/nirmalsharma-laravel-kafka-consumer/health.svg)](https://phpackages.com/packages/nirmalsharma-laravel-kafka-consumer)
```

PHPackages © 2026

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