我装了

"nmred/kafka-php": "0.2.*"

这个包，下面是官方的代码

<?php
require 'vendor/autoload.php';
date_default_timezone_set('PRC');
$config = \Kafka\ProducerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('192.168.83.50:9092');
$config->setBrokerVersion('1.1.0');
$config->setRequiredAck(1);
$config->setIsAsyn(false);
$config->setProduceInterval(500);
$producer = new \Kafka\Producer();

$result = $producer->send(array(
array(
    'topic' => 'test',
    'value' => 'test1....message.',
    'key' => '',
),
));
var_dump($result);

首先我在终端启动了生产者和消费者,发送消息消费者可以拿到的，服务启动应该是没有问题的。

php代码反馈结果是失败，不知什么原因