PHPackages                             hauptmedia/rdkafka - 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. hauptmedia/rdkafka

AbandonedArchivedLibrary

hauptmedia/rdkafka
==================

84.1k6PHP

Since Aug 19Pushed 7y ago3 watchersCompare

[ Source](https://github.com/hauptmedia/php-rdkafka)[ Packagist](https://packagist.org/packages/hauptmedia/rdkafka)[ RSS](/packages/hauptmedia-rdkafka/feed)WikiDiscussions master Synced 2mo ago

READMEChangelogDependenciesVersions (1)Used By (0)

php-rdkafka
===========

[](#php-rdkafka)

PHP stubs for the php rdkafka extension.

See

Wrapper / Facade objects in the Kafka namespace
===============================================

[](#wrapper--facade-objects-in-the-kafka-namespace)

You can use the wrapper objects available in the `Kafka` namespace for a more PHP-style interface to the RdKafka objects.

Example for a producer
----------------------

[](#example-for-a-producer)

```
include_once('vendor/autoload.php');

use Kafka\Configuration\ProducerConfiguration;
use Kafka\Manager;

$producerConfiguration = (new ProducerConfiguration())
    ->setRequestRequiredAcks(0);

$manager = new Manager(['hostname']);
$topic = $manager->createProducerTopicFacade("test", $producerConfiguration);

for($i=1;$iproduce(0 /* partition */, "test" . time());
}
```

### Example for a consumer

[](#example-for-a-consumer)

Implement the `\Kafka\ConsumerInterface` and add the class to the ConsumerTopicFacade object.

```
include_once('../vendor/autoload.php');

class MyConsumer implements \Kafka\ConsumerInterface {
    /**
     * @param string $topic Topic name
     * @param int $partition Partition
     * @param int $offset Message offset
     * @param string $key Optional message key
     * @param string $payload Message payload
     * @return mixed
     */
    public function consume($topic, $partition, $offset, $key, $payload)
    {
        echo "Received message with payload " . $payload;
    }
}
$consumerConfiguration = (new ConsumerConfiguration())
    ->setAutoCommitIntervalMs(1000)
    ->setOffsetStoreSyncIntervalMs(60);

$manager = new Manager(['hostname']);

$consumerTopic = $manager->createConsumerTopicFacade("test", $consumerConfiguration);
$consumerTopic->addConsumer(new MyConsumer());

$consumerTopic->consumeStart(0 /* partition */, 0 /* offset */);
$consumerTopic->consume(0 /* partition */, 1000 /* timeout in ms */);
$consumerTopic->consumeStop(0 /* partition */);
```

###  Health Score

27

—

LowBetter than 49% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity26

Limited adoption so far

Community14

Small or concentrated contributor base

Maturity40

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 90.9% 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.

### Community

Maintainers

![](https://www.gravatar.com/avatar/4af6f0b1b8c50a7240ac8f6d3ebf33a94a5a9990f57fd28c8e1e2e1d50e3416c?d=identicon)[hauptmedia](/maintainers/hauptmedia)

---

Top Contributors

[![hauptmedia](https://avatars.githubusercontent.com/u/10770719?v=4)](https://github.com/hauptmedia "hauptmedia (30 commits)")[![mshauneu](https://avatars.githubusercontent.com/u/5759779?v=4)](https://github.com/mshauneu "mshauneu (2 commits)")[![lpmi-13](https://avatars.githubusercontent.com/u/5070516?v=4)](https://github.com/lpmi-13 "lpmi-13 (1 commits)")

### Embed Badge

![Health badge](/badges/hauptmedia-rdkafka/health.svg)

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

PHPackages © 2026

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