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

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

1. Pulsar 事务介绍在 pulsar 中可以通过 produce 异常重试、consume 异常不 ack 的方式保证数据的不丢失，即 atleast-once 语义；Pulsar 提供了一个幂等（idempotent）producer 的特性，可以从 broker 侧对数据进行去重，但是幂...

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

1. Bookie启动时的Ledger存储相关内容Bookie启动时，会创建一个LedgerStorage。// 创建LedgerStoreledgerStorage = buildLedgerStorage(conf);...// 创建 SyncTrhead syncThread = new S...

消息同步首先在 PulsarService启动的时候，会注册一个删除 cluster 的 listener，当删除一个cluser时，会遍历所有的topic，关闭topic中对应cluster的replicator，并删除 cluster 对应的 pulsarClient。pulsarResourc...

Apache Pulsar 作为新一代的Message Queue, 可以提供很多有吸引力的特性：多副本低延迟读写分离一致性自动容错...这其中的很多特性都是依赖于底层存储组件 Apache BookKeeper来实现的。Apache Pulsar 中的存储图一展示了 Pulsar 的计算、存储分离...

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

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

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