安装kafka-php项目依赖

composer require nmred/kafka-php

produce.php

    setMetadataRefreshIntervalMs(10000);$config->setMetadataBrokerList('127.0.0.1:9092');$config->setBrokerVersion('0.10.2.1');$config->setRequiredAck(1);$config->setIsAsyn(false);$config->setProduceInterval(500);$producer = new \Kafka\Producer(function() {	$t = time();	return array(		array(			'topic' => 'test',			'value' => $t,			'key' => $t,		),	);});$producer->success(function($result) {	var_export($result);});$producer->error(function($errorCode) {	var_dump('error', $errorCode);});$producer->send();

consumer.php

    setMetadataRefreshIntervalMs(10000);$config->setMetadataBrokerList('127.0.0.1:9092');$config->setGroupId('test');$config->setBrokerVersion('0.10.2.1');$config->setTopics(array('test'));$consumer = new \Kafka\Consumer();$consumer->start(function($topic, $part, $message) {	var_dump($message);});

测试生产者

php produce.php

测试消费者

php consumer.php