PHP 编写的 kafka 客户端 kafka-php

Apache
PHP
跨平台
2017-04-28
nmred_2008

Kafka-php 使用纯粹的 PHP 编写的 kafka 客户端,目前支持 0.8.x 以上版本的 Kafka,该项目 v0.2.x 和 v0.1.x 不兼容,如果使用原有的 v0.1.x 的可以参照文档 Kafka PHP v0.1.x Document, 不过建议切换到 v0.2.x 上。v0.2.x 使用 PHP 异步执行的方式来和kafka broker 交互,较 v0.1.x 更加稳定高效, 由于使用 PHP 语言编写所以不用编译任何的扩展就可以使用,降低了接入与维护成本。

安装环境要求

  • PHP 版本大于 5.5

  • Kafka Server 版本大于 0.8.0

  • 消费模块 Kafka Server 版本需要大于 0.9.0

Installation

使用 Composer 安装

添加 composer 依赖 nmred/kafka-php 到项目的 composer.json 文件中即可,如:

{
	"require": {
		"nmred/kafka-php": "0.2.*"
	}
}

Produce

<?php
require '../vendor/autoload.php';
date_default_timezone_set('PRC');
use Monolog\Logger;
use Monolog\Handler\StdoutHandler;
// Create the logger
$logger = new Logger('my_logger');
// Now add some handlers
$logger->pushHandler(new StdoutHandler());

// 设置生产相关配置,具体配置参数见 [Configuration](Configuration.md)
$config = \Kafka\ProducerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('10.13.4.159:9192');
$config->setBrokerVersion('0.9.0.1');
$config->setRequiredAck(1);
$config->setIsAsyn(false);
$config->setProduceInterval(500);
$producer = new \Kafka\Producer(function() {
	return array(
		array(
			'topic' => 'test',
			'value' => 'test....message.',
			'key' => 'testkey',
		),
	);
});
$producer->setLogger($logger);
$producer->success(function($result) {
	var_dump($result);
});
$producer->error(function($errorCode, $context) {
	var_dump($errorCode);
});
$producer->send();

Consumer

<?php
require '../vendor/autoload.php';
date_default_timezone_set('PRC');
use Monolog\Logger;
use Monolog\Handler\StdoutHandler;
// Create the logger
$logger = new Logger('my_logger');
// Now add some handlers
$logger->pushHandler(new StdoutHandler());

$config = \Kafka\ConsumerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('10.13.4.159:9192');
$config->setGroupId('test');
$config->setBrokerVersion('0.9.0.1');
$config->setTopics(array('test'));
//$config->setOffsetReset('earliest');
$consumer = new \Kafka\Consumer();
$consumer->setLogger($logger);
$consumer->start(function($topic, $part, $message) {
	var_dump($message);
});

Basic Protocol

基础协议 API 调用方式见 Example

加载中

评论(0)

暂无评论

暂无资讯

暂无问答

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

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

2016/09/27 13:09
871
1
php5.6 centos7 kafka0.8.1

# 首先在保证php已经正确安装的情况下: # 安装jdk(本人安装jdk7) 和 scala 因为kafka基于scala开发 # 下载kafka wget http://mirrors.hust.edu.cn/apache/kafka/0.8.1.1/kafka-0.8.1.1-sr...

2015/11/24 14:54
43
0
转[喵咪KafKa(3)]PHP拓展See-KafKa

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

2016/10/13 16:00
42
0
几款消息中间的调研(转)

消息队列调研 消息系统简介 本次主要调研业界使用广泛的两款消息队列——RabbitMQ, Kafka, 以及阿里云的提供的两个服务, MNS和ONS. RabbitMQ RabbitMQ 是使用Erlang编写的一个开源的消息队...

2016/08/16 10:47
310
0
kafka与swoole多进程消费

环境:docker 容器:kafka、zookeeper、nginx 语言:php(lumen框架) 扩展:rdkafka,swoole 本文适合对kafka有一些了解的人阅览,因为没有写关于kafka原理的东西,可能也写不清楚吧哈哈哈。...

2018/12/25 10:32
11
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部