首页
学习
活动
专区
圈层
工具
发布

#pulsar

Pulsar存储计算分离架构设计之Broker无状态

老周聊架构

在分布式消息队列系统中,传统的架构模式如RocketMQ、RabbitMQ和Kafka等,通常将消息存储和消息处理逻辑集中在Broker节点上。这种模式虽然在一...

11010

聊聊 Pulsar:Consumer 源码解析

老周聊架构

继续跟进 org.apache.pulsar.client.impl.PulsarClientImpl#subscribeAsync(org.apache.pu...

9610

聊聊 Pulsar:Producer 源码解析

老周聊架构

核心在 org.apache.pulsar.client.impl.PulsarClientImpl#createProducerAsync(org.apach...

9410

Pulsar存储计算分离架构设计之消息副本同步和故障转移机制

老周聊架构

我们继续来讲Pulsar存储计算分离架构设计系列,这篇我们来说说消息副本和故障转移机制。

11310

Pulsar存储计算分离架构设计之负载均衡与分片管理

老周聊架构

我们继续来讲Pulsar存储计算分离架构设计系列,这篇我们来说说负载均衡与分片管理。

11610

Pulsar存储计算分离架构设计之元数据管理

老周聊架构

我们前面的Pulsar存储计算分离架构设计系列已经介绍过Broker无状态、存储层BookKeeper的文章了,这篇我们主要来说下元数据管理。

8510

Pulsar存储计算分离架构设计之存储层BookKeeper(下)

老周聊架构

我们继续跟着上一篇的server端的源码分析上来,直接看 org.apache.bookkeeper.proto.BookieRequestProcessor#...

7910

Pulsar存储计算分离架构设计之存储层BookKeeper(上)

老周聊架构

client端源码分析,可以找到pulsar的测试代码,具体类在org.apache.bookkeeper.mledger.SimpleBookKeeperTe...

10210

谁才是Kafka、Pulsar通吃的流计算王者?

gavin1024

23910

4月产品月报 | TDMQ Pulsar 版支持支持虚拟集群平滑迁移至专业集群

腾讯云中间件团队

关于腾讯云分布式消息队列 TDMQ TDMQ 是腾讯云自主研发的消息中间件产品系列,作为分布式系统中的关键组件,具备稳定可靠、高弹性、低成本的特性,提供异步通信...

13310

限流系列之三:TDMQ for Apache Pulsar 限流技术深度解析

腾讯云中间件团队

在高速、高吞吐量的消息处理场景中,TDMQ Pulsar 版以其卓越的性能和可扩展性成为众多企业的首选。然而,随着生产者和消费者以极高的速度生产/消费大量消息,...

25110

邀请函 | Pulsar Meetup 广州 2025 邀您报名!

腾讯云中间件团队

各位热爱 Pulsar 的小伙伴们,PulsarMeetup 广州 2025 大会来啦!这是 Pulsar 25 年开年第一场 Meetup,诚邀参与。本次还添...

16100

广州 Meetup|Pulsar AI+ 议题征集 | PulsarMeetup 广州 2025 大会正式启动!

腾讯云中间件团队

在议题提交过程中遇到问题,可微信联系 PulsarBot(微信号 pulsarbot)或者邮箱 pulsarbot@ascentstream.com 与我们联络...

40810

Apache Pulsar 技术系列 - 大规模延迟消息解析

腾讯云中间件团队

Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案,支持多租户、低延时、读写分离、跨地域复制(GEO replication)、快速扩容、...

36210

腾讯云上基于 Apache Pulsar 的大规模生产实践

腾讯云中间件团队

Pulsar Meetup 2024 北京站已经成功落下帷幕。在本次盛会中,腾讯云的高级工程师韩明泽和王震江为与会者带来了精彩的演讲。他们围绕多网接入、集群迁移...

20000

基于 TDMQ for Apache Pulsar 的跨地域复制实践

腾讯云中间件团队

自2024年9月6日起,TDMQ Pulsar 版专业集群支持消息、元数据两级跨地域复制功能,消息级复制解决用户全球地域的数据统一归档问题,元数据级复制提供解决...

32400

【干货】看看我司消息队列用啥,全网最接地气pulsar教程(含业务解耦demo源码)

JavaDog程序狗

通过简单代码demo进行讲解,pulsar在java中如何使用?如何通过pulsar进行异步解耦?......等

65510

pulsar + zookeeper(迁移zookeeper集群)

陳斯托洛夫斯記

修改pulsar配置,把pulsar配置中的zookeeper地址切换到新集群的节点上,重启pulsar服务,验证 pulsar 是否正常

35010

Flink 基于 TDMQ for Apache Pulsar 的离线场景使用实践

腾讯云开发者

Apache Flink 是一个开源的流处理和批处理框架,具有高吞吐量、低延迟的流式引擎,支持事件时间处理和状态管理,以及确保在机器故障时的容错性和一次性语义。...

48310
领券