PHPackages                             xiazhengxin/php\_rd\_kafka\_wrapper - 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. [HTTP & Networking](/categories/http)
4. /
5. xiazhengxin/php\_rd\_kafka\_wrapper

ActiveLibrary[HTTP & Networking](/categories/http)

xiazhengxin/php\_rd\_kafka\_wrapper
===================================

a good tool to pull/push from RD\_Kafka in PHP

v1.2(7y ago)010Apache-2.0PHPPHP >=7.0.0

Since Aug 23Pushed 7y ago1 watchersCompare

[ Source](https://github.com/sharljimhtsin/php_rd_Kafka_wrapper)[ Packagist](https://packagist.org/packages/xiazhengxin/php_rd_kafka_wrapper)[ Docs](https://github.com/sharljimhtsin/php_rd_Kafka_wrapper)[ RSS](/packages/xiazhengxin-php-rd-kafka-wrapper/feed)WikiDiscussions master Synced 2mo ago

READMEChangelogDependencies (2)Versions (4)Used By (0)

很方便的RD\_Kafka php 操作包装类
=======================

[](#很方便的rd_kafka-php-操作包装类)

demo
----

[](#demo)

```
//通过静态配置方法获取 生产者
$config = ["xxx" => "yyy"];
$kafkaConfig = \TPUtil\MQ::getKafkaConfig($config);
$producer = \TPUtil\MQ::getProducerByConfig($kafkaConfig);
$pTopic = $producer->newTopic("test");
$pTopic->produce(0, 0, "hehe");

//通过静态方法获取 消费者主题
$topic = \TPUtil\MQ::getConsumer()->newTopic("test");
//使用消费者主题实例 填充生成 MQ包装类 对象
$mq = new \TPUtil\MQ($topic);
//开始轮询RdKafka 主题内的消息队列
$mq->pullAllFromIt(function ($msg, $err) {
    var_dump($msg);// \RdKafka\Message 对象
    var_dump($err);// 错误信息
}, 0, 60 * 60 * 24 * 30 * 1000);
//停止轮询
$mq->stopPull();

```

安装
--

[](#安装)

添加到 composer.json 项

```
{
    "require-dev": {
        "xiazhengxin/php_rd_kafka_wrapper": "dev-master"
    }
}
```

更新 vendors 库

```
$ php composer.phar update xiazhengxin/php_rd_kafka_wrapper

```

依赖
--

[](#依赖)

librdkafka:  (系统动态链接库文件)

php-rdkafka:  (PHP 扩展DLL/SO)

Stubs for PHP Rdkafka extension:  (Composer 安装)

###  Health Score

25

—

LowBetter than 37% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity5

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity59

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

3

Last Release

2818d ago

### Community

Maintainers

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

---

Top Contributors

[![sharljimhtsin](https://avatars.githubusercontent.com/u/979353?v=4)](https://github.com/sharljimhtsin "sharljimhtsin (12 commits)")

---

Tags

phpphp-libraryrdkafkardkafka-extensionphplibraryrdkafka

### Embed Badge

![Health badge](/badges/xiazhengxin-php-rd-kafka-wrapper/health.svg)

```
[![Health](https://phpackages.com/badges/xiazhengxin-php-rd-kafka-wrapper/health.svg)](https://phpackages.com/packages/xiazhengxin-php-rd-kafka-wrapper)
```

###  Alternatives

[tsheetsteam/api_phplib

PHP Helper Library for TSheets API

112.1k](/packages/tsheetsteam-api-phplib)

PHPackages © 2026

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