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

ActiveLibrary

ayhome/kafka
============

kafka-php

09PHP

Since Nov 4Pushed 8y ago1 watchersCompare

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

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

\#ayhome-kafka kafka for php

\##前言

**一个基于kafka的客户端**

KafKa是由Apache基金会维护的一个分布式订阅分发系统,KafKa它最初的目的是为了解决,统一,高效低延时,高通量(同时能传输的数据量)并且高可用一个消息平台,它是分布式消息队列,分布式日志,数据传输通道的不二之选,本扩展是基于公司自身业务二次封装的!

**支持0.9~0.10版本**

**需要安装以下扩展**

librdkafka:[https://github.com/edenhill/librdkafka](https://github.com/edenhill/librdkafka "服务底层依赖")

rdkafka PHP:[https://github.com/arnaud-lb/php-rdkafka](https://github.com/arnaud-lb/php-rdkafka "rdkafka PHP拓展地址")

\##1. 安装zookeeper+KafKa

zookeeper+KafKa:[http://blog.csdn.net/lnho2015/article/details/51352966](http://blog.csdn.net/lnho2015/article/details/51352966 "zookeeper+KafKa")

```
# 安装librdkafka
git clone https://github.com/edenhill/librdkafka.git
cd librdkafka
./configure
make
make install

```

```
# 安装php-rdkafka
git clone https://github.com/arnaud-lb/php-rdkafka.git
cd php-rdkafka
phpize
./configure
make all -j 5
make install
# 在php.ini加入如下信息
vim /usr/local/php/etc/php.ini
extension=rdkafka.so

```

这个时候使用**php -m** 可以看到拓展列表内存在 rdkafka这项证明拓展已经安装成功

### 使用 Producer

[](#使用-producer)

KafKa最基础的两个角色其中一个就是Producer

向KafKa中的一个Topic写入一条消息,需要写入多条可以多次使用setMassage

```