redis和kafka读取代码

kafka读取代码如下所示:

<?php
$conf = new RdKafka\Conf();
//设置消费组
$conf->set('group.id', 'myConsumerGroup');

$rk = new RdKafka\Consumer($conf);
$rk->addBrokers("127.0.0.1");

$topicConf = new RdKafka\TopicConf();
$topicConf->set('request.required.acks', 1);

// 设置offset的存储为file
$topic = $rk->newTopic("test", $topicConf);

$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);

while (true) {
//参数1表示消费分区，这里是分区0
//参数2表示同步阻塞多久
$message = $topic->consume(0, 12 * 1000);
if (is_null($message)) {
echo "No more messages\n";
continue;
}
switch ($message->err) {
case RD_KAFKA_RESP_ERR_NO_ERROR:
var_dump($message);
break;
case RD_KAFKA_RESP_ERR__PARTITION_EOF:
echo "No more messages; will wait for more\n";
break;
case RD_KAFKA_RESP_ERR__TIMED_OUT:
echo "Timed out\n";
break;
default:
throw new \Exception($message->errstr(), $message->err);
break;
}
}

?>
redis读取代码如下所示:

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

for ($i = 0; $i < 20; $i++) {
//$redis->set("huancai . $i","huancai.$i");
$value=$redis->get("huancai . $i");
var_dump($value);
}

redis和kafka读取代码相关推荐

Redis、Kafka 和 Pulsar 消息队列对比
点击关注公众号,Java干货及时送达导语 | 市面上有非常多的消息中间件,rabbitMQ.kafka.rocketMQ.pulsar. redis等等,多得令人眼花缭乱.它们到底有什么异同,你应该 ...
Redis、Kafka 和 Pulsar 消息队列对比，写得太好了！
市面上有非常多的消息中间件,rabbitMQ.kafka.rocketMQ.pulsar. redis等等,多得令人眼花缭乱.它们到底有什么异同,你应该选哪个? 本文尝试通过技术演进的方式,以redi ...
面试官：请你从架构演进的角度讲讲redis、kafka和 pulsar消息队列
导语 | 市面上有非常多的消息中间件,rabbitMQ.kafka.rocketMQ.pulsar. redis等等,多得令人眼花缭乱.它们到底有什么异同,你应该选哪个?本文尝试通过技术演进的方式,以 ...
redis和kafka的写性能对比
kafka插入代码如下所示: <?php $conf = new RdKafka\Conf(); $rk = new RdKafka\Producer($conf); $rk->setLo ...
kafka redis vs 发布订阅_对比平台--Redis Vs Kafka 之间的区别
Redis和Kafka之间的区别在本文中,我们将探讨Redis与Kafka之间的最高差异和性能. Redis: Redis是一个内存中的键值数据存储,也是开源的.它可以非常快地用于缓存会话管理,高性 ...
旅游系统（SSM框架+MySQL+Redis+VUE）后端代码
旅游系统(SSM框架+MySQL+Redis+VUE)后端代码文章目录旅游系统(SSM框架+MySQL+Redis+VUE)后端代码 Controller 登录注册路线邮件退出头部信息 ...
SparkStream从kafka读取数据编码问题（Java）
SparkStreaming从kafka读取文件流时(Java),默认是utf-8的,如果源文件的编码不是utf-8,那就会出现乱码现象,但是kafka的官网参数里没有关于编码的参数,不过kafka的 ...
Redis，kafka，activeMQ，RabbitMQ,JVM, lMax Disrupt等实现的队列进行对比--开篇
前言结合前面提到的各种rabbitMQ的使用,本节开始综合的对比市场上流行的redis,kafka,activeMQ等的进行对比,附加使用的代码Demo提供参考.文章大致的结构分为,rabbitMQ ...
Kafka消费者——从 Kafka读取数据
应用程序使用 KafkaConsumer向 Kafka 订阅主题,并从订阅的主题上接收消息 . 从 Kafka 读取数据不同于从其他悄息系统读取数据,它涉及一些独特的概念和想法.如果不先理解这些概念 ...

redis和kafka读取代码

redis和kafka读取代码相关推荐

最新文章

热门文章