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