没有合适的资源?快使用搜索试试~ 我知道了~
kafka的PHP库(Composer).zip
共53个文件
php:42个
md:6个
yml:2个
需积分: 9 2 下载量 53 浏览量
2019-07-11
10:25:09
上传
评论
收藏 83KB ZIP 举报
温馨提示
Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志数据和离线分析系统,但又要求实时处理的限制,这是一个可行的解决方案。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理,也是为了通过集群来提供实时的消费。<?php namespace Kafka; class Broker { use SingletonTrait; private $groupBrokerId = null; private $topics = []; private $brokers = []; private $metaSockets = []; private $dataSockets = []; private $process; private $socket; private $config; public function setProcess(callable $process) { $this->process = $process; }
资源推荐
资源详情
资源评论
收起资源包目录
kafka-PHP客户端库(Composer).zip (53个子文件)
kafka-php-master
.coveralls.yml 129B
src
Protocol.php 14KB
Config.php 7KB
LoggerTrait.php 4KB
Consumer.php 3KB
Socket.php 6KB
Exception
NotSupported.php 1KB
Protocol.php 1KB
Config.php 1KB
Socket.php 93B
ConsumerConfig.php 4KB
Consumer
StopStrategy.php 160B
Process.php 30KB
Assignment.php 7KB
State.php 15KB
StopStrategy
Delay.php 618B
Callback.php 1KB
Producer
SyncProcess.php 7KB
Process.php 12KB
State.php 9KB
CommonSocket.php 6KB
Protocol
ApiVersions.php 3KB
FetchOffset.php 5KB
DescribeGroups.php 7KB
Protocol.php 20KB
Produce.php 9KB
CommitOffset.php 7KB
ListGroup.php 3KB
Fetch.php 12KB
GroupCoordinator.php 3KB
SaslHandShake.php 3KB
SyncGroup.php 7KB
Offset.php 6KB
Metadata.php 6KB
Heartbeat.php 3KB
LeaveGroup.php 2KB
JoinGroup.php 7KB
SingletonTrait.php 2KB
ProducerConfig.php 3KB
Exception.php 1KB
SocketSync.php 8KB
Producer.php 3KB
Broker.php 6KB
Dockerfile 103B
LICENSE 11KB
README_CH.md 5KB
README.md 5KB
docs
Configure.md 4KB
qq_group.png 7KB
error.md 2KB
ch
Configure.md 3KB
state.md 2KB
docker-compose.yml 1KB
共 53 条
- 1
资源评论
weixin_39840924
- 粉丝: 492
- 资源: 1万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功