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

《L03 构架 API 服务器》
你将学到如 RESTFul 设计风格、PostMan 的使用、OAuth 流程,JWT 概念及使用 和 API 开发相关的进阶知识。
《L02 从零构建论坛系统》
以构建论坛项目 LaraBBS 为线索,展开对 Laravel 框架的全面学习。应用程序架构思路贴近 Laravel 框架的设计哲学。
讨论数量: 2
nfangxu

你是怎么启动的呢

4年前 评论

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

4年前 评论

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