在分布式消息队列系统中,传统的架构模式如RocketMQ、RabbitMQ和Kafka等,通常将消息存储和消息处理逻辑集中在Broker节点上。这种模式虽然在一...
继续跟进 org.apache.pulsar.client.impl.PulsarClientImpl#subscribeAsync(org.apache.pu...
核心在 org.apache.pulsar.client.impl.PulsarClientImpl#createProducerAsync(org.apach...
我们继续来讲Pulsar存储计算分离架构设计系列,这篇我们来说说消息副本和故障转移机制。
我们继续来讲Pulsar存储计算分离架构设计系列,这篇我们来说说负载均衡与分片管理。
我们前面的Pulsar存储计算分离架构设计系列已经介绍过Broker无状态、存储层BookKeeper的文章了,这篇我们主要来说下元数据管理。
我们继续跟着上一篇的server端的源码分析上来,直接看 org.apache.bookkeeper.proto.BookieRequestProcessor#...
client端源码分析,可以找到pulsar的测试代码,具体类在org.apache.bookkeeper.mledger.SimpleBookKeeperTe...
关于腾讯云分布式消息队列 TDMQ TDMQ 是腾讯云自主研发的消息中间件产品系列,作为分布式系统中的关键组件,具备稳定可靠、高弹性、低成本的特性,提供异步通信...
在高速、高吞吐量的消息处理场景中,TDMQ Pulsar 版以其卓越的性能和可扩展性成为众多企业的首选。然而,随着生产者和消费者以极高的速度生产/消费大量消息,...
各位热爱 Pulsar 的小伙伴们,PulsarMeetup 广州 2025 大会来啦!这是 Pulsar 25 年开年第一场 Meetup,诚邀参与。本次还添...
在议题提交过程中遇到问题,可微信联系 PulsarBot(微信号 pulsarbot)或者邮箱 pulsarbot@ascentstream.com 与我们联络...
Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案,支持多租户、低延时、读写分离、跨地域复制(GEO replication)、快速扩容、...
Pulsar Meetup 2024 北京站已经成功落下帷幕。在本次盛会中,腾讯云的高级工程师韩明泽和王震江为与会者带来了精彩的演讲。他们围绕多网接入、集群迁移...
自2024年9月6日起,TDMQ Pulsar 版专业集群支持消息、元数据两级跨地域复制功能,消息级复制解决用户全球地域的数据统一归档问题,元数据级复制提供解决...
通过简单代码demo进行讲解,pulsar在java中如何使用?如何通过pulsar进行异步解耦?......等
修改pulsar配置,把pulsar配置中的zookeeper地址切换到新集群的节点上,重启pulsar服务,验证 pulsar 是否正常
Apache Flink 是一个开源的流处理和批处理框架,具有高吞吐量、低延迟的流式引擎,支持事件时间处理和状态管理,以及确保在机器故障时的容错性和一次性语义。...