php生产和消费kafka消息示例代码
代码语言:phpcli
所属分类:通讯
代码描述:php生产和消费kafka消息示例代码
代码标签: php 生产 消费 kafka 消息 示例 代码
下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开
<?php //消息生产 $rcf = new RdKafka\Conf(); $rcf->set('group.id', 'test'); //topicname $cf = new RdKafka\TopicConf(); $cf->set('offset.store.method', 'broker'); $cf->set('auto.offset.reset', 'smallest'); $rk = new RdKafka\Producer($rcf); $rk->setLogLevel(LOG_DEBUG); $rk->addBrokers("127.0.0.1"); //brokeraddr $topic = $rk->newTopic("test", $cf); //topicname for ($i = 0; $i < 10; $i++) { $topic->produce(0, 0, 'test' . $i); } //消息消费 $rcf = new RdKafka\Conf(); $rcf->set('group.id', .........完整代码请登录后点击上方下载按钮下载查看
网友评论0