Prev Next

Integration / Apache Pulsar Interview questions

Explain the lifecycle of a message in Pulsar from produce to acknowledge?

A producer connects to the broker currently owning the target topic (discovered via a lookup against the metadata store) and sends a message, optionally batched with others and assigned a sequence ID for deduplication.

The owning broker validates the message against the topic's configured schema, applies routing (for partitioned topics), and forwards the entry to a BookKeeper ensemble, waiting for the configured ack quorum of bookies to durably confirm the write before acknowledging success back to the producer.

Once durably stored, the message becomes available to every active subscription on the topic; the broker dispatches it according to each subscription's type, pushing it to the appropriate connected consumer(s).

A consumer processes the message and sends an acknowledgment back to the broker, which advances that subscription's cursor position (itself persisted, via a managed ledger) so the message is no longer part of that subscription's backlog; if left unacknowledged, it remains eligible for redelivery.

Once every subscription on the topic has acknowledged a message and the configured retention window (if any) allows it, the message becomes eligible for deletion from BookKeeper, or for offload to tiered storage if it's aged past the offload threshold instead.

sequenceDiagram
  participant P as Producer
  participant B as Broker
  participant BK as BookKeeper ensemble
  participant C as Consumer
  P->>B: Publish message (lookup + send)
  B->>BK: Write entry to ledger
  BK-->>B: Ack quorum confirms durable write
  B-->>P: Publish acknowledged
  B->>C: Dispatch per subscription type
  C-->>B: Acknowledge
  B->>B: Advance subscription cursor
The producer's write is acknowledged as durable once:
A message is only eligible for deletion once:

Invest now in Acorns!!! 🚀 Join Acorns and get your $5 bonus!
Acorns Logo

Invest now in Acorns!!! 🚀
Join Acorns and get your $5 bonus!

Earn passively and while sleeping

Acorns is a micro-investing app that automatically invests your "spare change" from daily purchases into diversified, expert-built portfolios of ETFs. It is designed for beginners, allowing you to start investing with as little as $5. The service automates saving and investing. Disclosure: I may receive a referral bonus.

Robinhood Logo

Invest now!!! Get Free equity stock (US, UK only)!

Use Robinhood app to invest in stocks. It is safe and secure. Use the Referral link to claim your free stock when you sign up!.

The Robinhood app makes it easy to trade stocks, crypto and more.


Webull Logo

Webull! Receive free stock by signing up using the link: Webull signup.

More Related questions...

Explain about Apache Pulsar. What is Apache Pulsar? What is a Pulsar broker? What is Apache BookKeeper? What are tenants and namespaces in Pulsar? What is a topic in Pulsar? What is a producer in Pulsar? What is a consumer in Pulsar? What is a subscription in Pulsar? Define a partitioned topic in Pulsar? What is Pulsar's metadata store used for? What are Pulsar Functions? What is Pulsar IO? Describe geo-replication in Pulsar? What is tiered storage in Pulsar? What is a non-persistent topic in Pulsar? What are the subscription types in Pulsar? What is message retention in Pulsar? What is schema registry in Pulsar? List the core components of a Pulsar cluster? How do you create a topic in Pulsar? What is the difference between Pulsar and Kafka's storage architecture? How does Pulsar separate compute and storage? Why is Pulsar considered multi-tenant by design? What is the difference between Shared and Exclusive subscriptions? How does Key_Shared subscription maintain ordering? When should you use Failover subscription instead of Exclusive? What is the difference between a ledger and a segment in BookKeeper? How does Pulsar achieve message deduplication? Why do brokers in Pulsar not store data locally? What happens when a broker crashes in Pulsar? How does namespace bundle splitting work? What is the difference between backlog quota and retention policy? When should you use a Reader instead of a Consumer? How does topic compaction work in Pulsar? Why is ensemble size different from write quorum in BookKeeper? What is the difference between persistent and non-persistent topics? How does Pulsar handle delayed message delivery? What happens when a consumer negatively acknowledges a message? Explain the lifecycle of a message in Pulsar from produce to acknowledge? How can you optimize Pulsar for high-throughput workloads? How do you troubleshoot a growing backlog in Pulsar? Explain the execution flow of topic ownership failover in Pulsar? How can you optimize BookKeeper storage costs using tiered storage? Explain the internal working of Pulsar transactions? Which is better for exactly-once processing: idempotent producers or transactions, and why? How do you troubleshoot unbalanced load across brokers? Explain the lifecycle of a namespace bundle from creation to split? How can you optimize consumer throughput with Key_Shared subscriptions? Explain the execution flow of a Pulsar Function processing a message? How do you troubleshoot message duplication in a Pulsar producer?
Show more question and Answers...

Apache Camel Interview Questions

Comments & Discussions