Tagged articles
6 articles
Page 1 of 1
Tencent Cloud Developer
Tencent Cloud Developer
Dec 24, 2021 · Cloud Native

Deep Dive into Apache Pulsar Message Acknowledgment Mechanism

Apache Pulsar ensures reliable delivery by letting consumers acknowledge messages individually, cumulatively, or within batches, while also supporting negative acknowledgments and sophisticated tracking mechanisms that batch ack requests, use BitSet for batch indexes, and employ time‑wheel‑based redelivery for unacknowledged messages.

Apache PulsarConsumer TrackerDistributed Messaging
0 likes · 10 min read
Deep Dive into Apache Pulsar Message Acknowledgment Mechanism
High Availability Architecture
High Availability Architecture
Dec 24, 2021 · Backend Development

Understanding Broker‑Side Message Acknowledgment and Cursor Management in Apache Pulsar

This article explains how Apache Pulsar brokers track consumer acknowledgment using cursors, describes persistent and non‑persistent subscription differences, details cursor metadata stored in ZooKeeper and BookKeeper, and outlines optimizations for handling message gaps, including RangeSet improvements and a new LRU‑based storage design.

Apache PulsarBookKeeperBroker
0 likes · 12 min read
Understanding Broker‑Side Message Acknowledgment and Cursor Management in Apache Pulsar
Tencent Cloud Middleware
Tencent Cloud Middleware
Dec 20, 2021 · Backend Development

How Pulsar Brokers Manage Message Acknowledgments and Cursor Gaps

This article explains how Apache Pulsar brokers track consumer acknowledgments using cursors, store metadata in ZooKeeper and BookKeeper, handle acknowledgment gaps with range sets, and optimize memory usage through LRU and segmented storage to ensure reliable message delivery.

Apache PulsarBookKeeperBroker
0 likes · 15 min read
How Pulsar Brokers Manage Message Acknowledgments and Cursor Gaps
JavaEdge
JavaEdge
Apr 12, 2021 · Backend Development

Ensuring Reliable Message Consumption with RabbitMQ in Java

This guide explains how to configure RabbitMQ in Java to prevent message loss, demonstrates the difference between automatic and manual acknowledgments, and shows how to handle consumption errors using basicNack for requeueing or discarding messages.

JavaMessage AcknowledgmentRabbitMQ
0 likes · 4 min read
Ensuring Reliable Message Consumption with RabbitMQ in Java