书白 comments

Results 3 comments of


                                            书白

（The consumers at 2.12, 1.0.0 can't read the data）2.12 1.0.0 的消费者无法读取数据

`require './vendor/autoload.php'; date_default_timezone_set('PRC'); use Monolog\Logger; use Monolog\Handler\StreamHandler; $config = \Kafka\ConsumerConfig::getInstance(); $config->setMetadataRefreshIntervalMs(10000); $config->setMetadataBrokerList('127.0.0.1:9092'); $config->setGroupId('test'); $config->setBrokerVersion('1.0.0'); $config->setTopics(array('test')); //$config->setOffsetReset('earliest'); $consumer = new \Kafka\Consumer(); $consumer->setLogger($log); $consumer->start(function($topic, $part, $message) { var_dump($message); }); ` PHP 7.2.0...

（The consumers at 2.12, 1.0.0 can't read the data）2.12 1.0.0 的消费者无法读取数据

kafka version is kafka_2.12-1.0.0.tgz。kafka-php version is "nmred/kafka-php": "v0.2.0.8",

（The consumers at 2.12, 1.0.0 can't read the data）2.12 1.0.0 的消费者无法读取数据

Thank you, I'll try。