PHPackages                             liangtao/kafka-php - 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. liangtao/kafka-php

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

liangtao/kafka-php
==================

PHP client for Kafka version 2.7.1

1.0.2(3y ago)042Apache-2.0PHPPHP >=8.0.12

Since Nov 16Pushed 3y ago1 watchersCompare

[ Source](https://github.com/liangtao-top/kafka-php)[ Packagist](https://packagist.org/packages/liangtao/kafka-php)[ Docs](https://github.com/liangtao-top/kafka-php)[ RSS](/packages/liangtao-kafka-php/feed)WikiDiscussions main Synced today

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

Kafka-php
=========

[](#kafka-php)

[![Build Status](https://camo.githubusercontent.com/25ca7df9689883a2b2813d043545ac41b7fac08a34927a51098a721157b34ed0/68747470733a2f2f7472617669732d63692e636f6d2f6c69616e6774616f2d746f702f6b61666b612d7068702e7376673f6272616e63683d6d61696e)](https://travis-ci.com/github/liangtao-top/kafka-php)[![Packagist](https://camo.githubusercontent.com/fe3f8e5d18a2d0ea399d225f26d642c5a7e781f347c2d889e653a7b4ec222374/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f646d2f6c69616e6774616f2f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://packagist.org/packages/liangtao/kafka-php)[![Packagist](https://camo.githubusercontent.com/bb7f2cc071f300563138765235cdc8ef1d50e21f342297399a0c7bd30a9ab137/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64642f6c69616e6774616f2f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://packagist.org/packages/liangtao/kafka-php)[![Packagist](https://camo.githubusercontent.com/0f0560bb64fc4404889eb788629ca81fd74bf3233551c03c70588ffe494de2c9/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64742f6c69616e6774616f2f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://packagist.org/packages/liangtao/kafka-php)[![GitHub issues](https://camo.githubusercontent.com/9ddcc46b356eeee8be2fd071d85f7fb60e5b2fe4965d40399fe3bfc89556ed86/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f6973737565732f6c69616e6774616f2d746f702f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://github.com/liangtao-top/kafka-php/issues)[![GitHub forks](https://camo.githubusercontent.com/2c2b15a7f319fd2a12d82341420c66fa4ed8efea81b64ad1f1af4d0fad3b209f/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f666f726b732f6c69616e6774616f2d746f702f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://github.com/liangtao-top/kafka-php/network)[![GitHub stars](https://camo.githubusercontent.com/24812e8599dc7ffbe02f1cdfaf947c8712c9de4ebbcd02641d45f9b41a3ce291/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f73746172732f6c69616e6774616f2d746f702f6b61666b612d7068702e7376673f7374796c653d706c6173746963)](https://github.com/liangtao-top/kafka-php/stargazers)[![GitHub license](https://camo.githubusercontent.com/f123f9fed5c4a86bb78ea213fcef0db957ac50229e2588cb2fc702a3d9764971/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f6c6963656e73652d417061636865253230322d626c75652e7376673f7374796c653d706c6173746963)](https://raw.githubusercontent.com/liangtao-top/kafka-php/main/LICENSE)

Kafka-php 使用纯粹的PHP 编写的 kafka 客户端，目前支持 2.7.1 以上版本的 Kafka，使用 PHP 异步执行的方式来和kafka broker 交互，由于使用 PHP 语言编写所以不用编译任何的扩展就可以使用，降低了接入与维护成本

安装环境要求
------

[](#安装环境要求)

- PHP version >= 8.0.12
- Kafka version >= 2.7.1

使用 Composer 安装
--------------

[](#使用-composer-安装)

```
composer require liangtao/kafka-php

```

添加 composer 依赖 `liangtao/kafka-php` 到项目的 `composer.json` 文件中即可，如：

```
{
	"require": {
		"liangtao/kafka-php": ">=1.0.0"
	}
}

```

配置
--

[](#配置)

配置参数见 [配置](docs/Configure.md)

Produce
-------

[](#produce)

### 异步回调方式调用

[](#异步回调方式调用)

```