kafka 消费问题
请教大家一个问题: kafka生产没问题 消息能正常发送进队列 但消费始终得不到数据 一直在加载中,扩展"nmred/kafka-php": "v0.2.0.8"
php:7.3.1
$config = \Kafka\ConsumerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('xxx.xxx.xxx.xxx:9092');
$config->setGroupId('test');
$config->setBrokerVersion('1.0.0');
$config->setTopics(array('test'));
$consumer = new \Kafka\Consumer();
$consumer->start(function($topic, $part, $message) {
var_dump($message['message']['value']);
});
参考文章:Kafka-php 使用纯粹的 PHP 编写的 kafka 客户端
请教大家有遇到这个问题吗 如何解决的?
你是怎么启动的呢
😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊