Client Kafka écrit en PHP

Kafka-php utilise un client kafka écrit en PHP pur. Il prend actuellement en charge la version 0.8.x ou supérieure de Kafka. Les projets v0.2.x et v0.1.x sont incompatibles si vous utilisez la v0.1 d'origine. Pour le .x, vous pouvez vous référer au document Kafka PHP v0.1.x Document, mais il est recommandé de passer à la v0.2.x. La v0.2.x utilise l'exécution asynchrone PHP pour interagir avec le courtier kafka, qui est plus stable et efficace que la v0.1.x. Puisqu'il est écrit en langage PHP, il peut être utilisé sans compiler d'extensions, ce qui réduit l'accès et la maintenance. frais.

Environnement d'installation requis

• La version PHP est supérieure à 5.5

• La version de Kafka Server est supérieure à 0.8.0

• La version du module de consommation Kafka Server doit être supérieure à 0.9.0

Installation

Utiliser Composer pour installer

Ajoutez un compositeur pour dépendre de nmred/kafka -php au fichier composer.json du projet, tel que :

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

Produce

<?php
require &#39;../vendor/autoload.php&#39;;
date_default_timezone_set(&#39;PRC&#39;);
use Monolog\Logger;
use Monolog\Handler\StdoutHandler;
// Create the logger
$logger = new Logger(&#39;my_logger&#39;);
// 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();

Consommateur

<?php
require &#39;../vendor/autoload.php&#39;;
date_default_timezone_set(&#39;PRC&#39;);
use Monolog\Logger;
use Monolog\Handler\StdoutHandler;
// Create the logger
$logger = new Logger(&#39;my_logger&#39;);
// 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);
});

Le contenu ci-dessus est un tutoriel client Kafka écrit en PHP. J'espère qu'il pourra aider tout le monde.

Recommandations associées :

Exemple de prise de contact entre le client et le serveur de Socket en python

php obtient l'adresse IP et géographique du visiteur (client) tutoriel texte de localisation

Comment développer rapidement un client webservice ?

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!