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 客户端
请教大家有遇到这个问题吗 如何解决的?

《L01 基础入门》
我们将带你从零开发一个项目并部署到线上,本课程教授 Web 开发中专业、实用的技能,如 Git 工作流、Laravel Mix 前端工作流等。
《G01 Go 实战入门》
从零开始带你一步步开发一个 Go 博客项目,让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。
讨论数量: 2
nfangxu

你是怎么启动的呢

4年前 评论

😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊😊

4年前 评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!