作者:徐新nina | 来源:互联网 | 2023-10-11 09:14
我装了
"nmred/kafka-php": "0.2.*"
这个包,下面是官方的代码
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
| 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代码反馈结果是失败,不知什么原因