Pulsar broker负载均衡原理和实现[toc]Pulsar 的负载均衡策略的目的是为了将负载均匀的分配在集群不同的 broker 上。1. Broker 分类从负载均衡的角度看，broker 可以分为两类leader broker：负载汇总、更新负载信息其他 broker：计算自己的负载信息...

Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO replication）、快速扩容、灵活容错等特性，GEO replication 可以原生支持数据和订阅状态在多个集群之间进行复制，本文主要讲述 GEO 中的订阅状态的同步。...

Pulsar Schema...

Chunk message简介...

Pulsar的数据一致性保证...

Pulsar 数据生命周期Pulsar 作为一个 MQ，核心流程就是数据的生产和消费，对于已经写入 MQ 的数据，数据的保存和删除策略也尤为重要。...

Pulsar 事务实现1.1 事务准备1.1.1 初始化事务元数据通过事务元数据初始化命令来执行元数据初始化操作：bin/pulsar initialize-transaction-coordinator-metadata-cs 127.0.0.1:2181 # configuration sto...

初始化 PulsarService时，首先为负载均衡初始化一个单线程的线程池this.loadManagerExecutor = Executors .newSingleThreadScheduledExecutor(new DefaultThreadFactory(&...

Pulsar 作为一个消息传输的解决方案，最基本的功能是提供了pub/sub模型的消息服务，即作为一个消息中间件的能力，本文主要以Java Client为例讲述消费者和Broker之间的交互过程。...

Publish工作原理向Pulsar Publish数据，需要首先初始化一个producer，初始化的过程中可以为producer指定一些属性pulsarClient.newProducer() .enableBatching(true) // 开启batch ...