php-kafka-consumer

MIT
PHP
跨平台
2016-12-29
git-hulk

php-kafka-consumer 主要是对 php_rdkafka 的 consumer 的 API 进行一层封装,增加了原程序中所没有的与 zookeeper 交互的功能。在此基础上实现了 rebalance 功能以及 group 功能。 经过简单的压力测试,单个进程的消费能力能达到每秒钟7.8W条,压测详细内容见压力测试

依赖

php_zookeeper

php_rdkafka (建议使用1.0.0版本)

librdkafka(建议使用0.9.1版本)

使用

<?php 
include 'consumer.php';

function call_back_func($msg) {
    echo "$msg->payload\n";
}

function handle_error_call_back($msg) {
    echo $msg->errstr();
}

$consumer = New Consumer("localhost:2181");
$consumer->setGroupId("group-test");
$consumer->setTopic("topic-test");
$consumer->setOffsetAutoReset(Consumer::smallest);
$consumer->setErrHandler("handle_error_call_back");

try {
    $consumer->start("echo_message");
}
catch(Exception $e) {
    printf("error: %s\n", $e->getMessage());
}
加载中

评论(0)

暂无评论

暂无资讯

暂无问答

[喵咪KafKa(3)]PHP拓展See-KafKa

KafKa是由Apache基金会维护的一个分布式订阅分发系统,KafKa它最初的目的是为了解决,统一,高效低延时,高通量(同时能传输的数据量)并且高可用一个消息平台,它是分布式消息队列,分布式日志,数据...

2016/09/27 13:09
882
1
转[喵咪KafKa(3)]PHP拓展See-KafKa

前言 (Simple 简单 easy 容易 expand 的拓展) KafKa是由Apache基金会维护的一个分布式订阅分发系统,KafKa它最初的目的是为了解决,统一,高效低延时,高通量(同时能传输的数据量)并且高可用一个...

2016/10/13 16:00
42
0
kafka初级

一、入门 1. 简介 Kafka is a distributed, partitioned, replicated commit log service。它提供了类似于JMS的特性,但是在设计实现上完全不同,此外它并不是JMS规范的实现。kafka对消息保存...

2015/03/30 11:33
34
0
Kafka生产者消费者模型学习

Kafka生产者消费者模型学习

2015/09/30 15:47
400
0
Kafka 之 入门

最近研究采集层,对Kafka做了一个研究。分为入门,中级,高级步步进阶。本篇主要介绍基本概念,适用场景。

2014/08/18 12:45
30.2K
6
kafka--高性能的分布式消息系统

kafka是一个分布式的,高吞吐量的、信息分片存储,消息同步复制的开源消息服务,它提供了消息系统的功能,但是采用了独特的设计。

2016/05/10 14:59
948
5
Burrow 1.1.0实战

Burrow是个什么东西?这里就不做详细介绍了,之前写过相关文章Linkedin Burrow,本文只是实战最新版v1.1.0。最新版的配置和接口和之前的老版有些区别,github上项目还在更新,希望不要成为一...

2018/10/09 09:09
193
0
kafka定义

定义: Apache Kafka® is a distributed streaming platform. A streaming platform has three key capabilities(流平台的三个定义): Publish and subscribe to streams of records, simil...

2018/06/28 22:09
15
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部