Chris Bartholomew

I’ve been asked a few times about whether <a href="https://kesque.com/what-is-apache-pulsar/">Apache Pulsar</a> supports multiple groups of consumers (or consumer groups) on a topic. In other words, if multiple applications can consume messages from a single topic. The answer is definitely yes. In fact, Pulsar is very good at this.

In this post, I will show you how that works. I will be using our managed Apache Pulsar service to demonstrate (which you can <a href="https://kafkaesque.io/wp-login.php?action=register">try for free</a>). But you can do exactly the same things if you are running your own Apache Pulsar cluster or standalone instance.

<h3>Subscriptions</h3>

The first thing to understand is that Pulsar manages consumers on topics using subscriptions. A subscription keeps track of the messages in the topic that are to be delivered to one or more consumers. When a consumer connects to a topic in Pulsar, it specifies the subscription it is using. The subscription keeps track of the position in the topic from which the consumer is reading. As the consumer reads and acknowledges a message, its read position in the topic is automatically updated.

<h3>Multiple Subscriptions on a Topic</h3>

A Pulsar topic can support many subscriptions at the same time. This means that multiple consumers (or groups of consumers) can be reading messages from the topic simultaneously. So, you can have multiple applications consuming from a topic, each getting their own copy of the message and each having a different read position.

For example, if a publisher publishes a message to a topic that has three subscriptions, one for each consuming application, then that message will be sent to each subscription. For every message published to that topic, three copies of that message are consumed. This is how Pulsar provides message fan-out to multiple applications.

<h3>Multiple Consumers in Subscription</h3>

To fan-out messages to multiple applications, you just need to add subscriptions to your Pulsar topic. Within each subscription, there can be one or more consumers. Pulsar supports four different types of subscriptions which vary based on how the messages are sent to the consumers of that subscription.

<h3>Exclusive subscription</h3>

With an exclusive subscription, one and only one consumer is allowed to use the subscription at any given time. If another consumer attempts to use the subscription, it will be rejected. This is useful if there is a strict need for the messages in the topic to be consumed in order by a specific application.

<h3>Failover subscription</h3>

With a failover subscription, multiple consumers can use the subscription. But only one is allowed to be active or consuming at a time. This type of subscription makes sense if your application runs in an active-standby configuration. If the active fails, the standby is able to pick up where the active left off. Both applications connect to the subscription but only one consumes messages from the topic.

<h3>Shared subscription</h3>

A shared subscription allows multiple consumers to consume from the topic at the same time. The messages are sent round-robin to each connected consumer. This subscription allows you to implement the classic “<a href="https://www.enterpriseintegrationpatterns.com/patterns/messaging/CompetingConsumers.html">competing consumers</a>” pattern of a work queue. If your application can be horizontally scaled, you can use the shared subscription to distribute the work to multiple instances of the application.

<h3>Example: Multiple Applications Consuming From Topic</h3>

Enough of the theoretical talk, let’s see this in action. We are going to publish messages to a topic that are consumed by two different applications. One application needs to process the message in strict order, so it is going to use an exclusive subscription. If the application goes down, it will rely on Pulsar to persist the messages and deliver the messages to it when it recovers.

The second application is consuming from the same topic, but it is horizontally scalable. The order of the messages is not important, but the processing time for each message is long, so multiple copies of the application are needed to keep up with the publishing rate. This application is going to use a shared subscription.

First, we create a Pulsar topic called “subscription-demo”, which looks like this in the <a href="https://kafkaesque.io/">Kesque </a>user interface:

<img height="269" src="https://lh5.googleusercontent.com/dODHW8CpHE3ozS2yUMdL4Tuvh2BA1qtnvHtXT84qk8vV0KxWhCRdJWP8mG_T-61fkmJWOwdX6w4_21viVW6u6xMgGgxKMMSoGK72xsDESaDo6v5mWIzdLFlsccybHkeT2tBpkG6z" width="624" />

As you can see, there are no subscriptions on the topic yet. We will connect a Python client to the topic using an exclusive subscription which will automatically create a subscription. Here is the code we are going to use:

<img height="508" src="https://lh5.googleusercontent.com/l1bXkVyD_mj90AF5GfaKy3zkBRWZP5sy0WihnsZm3OrvoQJ4C_DwaaXkqa6Gf2SCWAOXP0WCiROod86sGFRxJPDjnFy1To5gGpG2N4TtrG2SqybNzsra_l2gAfnon3Cv3qDP8X3k" width="624" />

Note that in line 12 we are specifying the consumer_type as Exclusive when subscribing, but this is the default, so it can be omitted if you are using an exclusive subscription.

When that client connects, it looks like this:

<img height="345" src="https://lh6.googleusercontent.com/glVv9AqqZFZjN3agp2FvemWy9PkbRbAEgEN9ITzwB-8riU9XhJSN8bBA4JQSTPmNC91fhXsbqKSzh2I_L5NEiSi_Y4p3h97EmM6xZ-icmtO6R0gpZ_rcpsYyrXxxcPFj4HsRZ-ue" width="624" />

The topic now has one subscription with one connected consumer. The subscription type is Exclusive.

Now, we are going to create a shared subscription using the following Python client code. It’s the same as previous code except we changed the consumer_type to Shared on line 12 (and the name of the subscription on line 11):

<img height="505" src="https://lh6.googleusercontent.com/7mdUoy1g0xBDb7GdJA4v2ykdAZPHrwSAZ9PbtmN8MBM2kaqoZmgXULFS6fWZhWHlWYnESP5y-EagiUVLeR1PXDI4GgEXryzWO_WorkjqhTFwSuOpH8PoiYryf4lMiiSH8FNhVjHw" width="624" />

Since this application is horizontally scalable, we are going to run two copies of the Python code in different terminals. This simulates two independent copies of the application:

<img height="377" src="https://lh3.googleusercontent.com/1Xb05qDi100SIhKqW8_qZVInDi2P-UBdHeTbRCr0RSbsDbQMJkMd6YkNiMlpbdRPMUcyR1RgeSZV9p78et5cKKlFvMm66CwzK2f73PKQs9IYH1OMx91EufbyO3U7g83jz6E-DJi6" width="624" />

Now, the topic has a second subscription of the Shared type with two connected consumers.

At this point, we have a total of three consumers on this topic. One is using an exclusive subscription, so that consumer will receive a copy of each message published to the topic. The other 2 consumers are using a shared subscription, so between the two of them they will receive a copy of each message published to the topic. Pulsar will deliver the messages in a round-robin fashion to the consumers of the shared subscription.

Now let’s publish six messages to the topic using this Python code:

<img height="348" src="https://lh6.googleusercontent.com/laI2X9EOtStwoEb6a3OJE27JkRXY21BEL5lZU3dldh2nag9_E2f-6TEFQbO9db1SYiey0Dn9pkZrP4xApo3JXn0zGPDisB1l7-7cLlv_ZeDF5Eo-V3Z1v5Xi06b6-qy5meYzEuvA" width="624" />

This is what we see on the consumer connected to the exclusive subscription:

<img height="201" src="https://lh3.googleusercontent.com/TwQRu8g7We-4Hniyf84nGZkjJ672ToCS7fYEbKDTeOvz30oeDOQRywq4sK_6uyLTZSmExgQtN61ZGlD69nAab-VCU9Qg0XhEY2VgHotiqgKhdaUWADodSjwaL1LF1YUVHU4haq-f" width="624" />

As expected, this consumer receives all six published messages.

Now, let’s look at the first consumer on the shared subscription:

<img height="165" src="https://lh4.googleusercontent.com/Y8wkwvy_z0BJ3sAMjOmNilMKdabyAPJdUg2Y1iQXUk-uRTiVrEnEovI3oaQWL6ZzwVzdW-bmwCng_rCH-tbEISOqUj26Yy46Gs1FWP7NJlFxO5vi7gUzcfsf3CmmqR-QO1U0O27R" width="624" />

This consumer gets all the even-numbered messages. This makes sense since the messages will be evenly distributed between the two connected consumers. As expected, the other consumer on the shared subscription gets all the odd-numbered messages:

To recap, we published six messages to the topic. Those six messages were received by two different applications using different subscriptions. One application is using an exclusive subscription, so it received all six messages. The other application is using a shared subscription with two consumers. It also received six messages, but they were evenly distributed between the two consumers with each consumer getting three messages each.

Now, let’s disconnect all the consumers and publish six messages again. Pulsar will store those messages persistently for when the consumers come back online. This is what that looks like:

<img height="189" src="https://lh5.googleusercontent.com/DSmEM_tHIdB_UAD-t7k_v8LliqbeznxefEfgixLg3in6Z1qnvAVC8Do9qTfpsouDM9SpfDJTiwl3mRVvztStrRowmncTb5XrM8Vuf_uZQo_PJ--NdH99n-K-L0LKK1IyYvgW-Ct1" width="624" />

As you can see, Pulsar has stored those six messages in the message backlog for each of the subscriptions. We can view the messages in exclusive subscription backlog using the Peek function:

<img height="459" src="https://lh5.googleusercontent.com/_F8MjI8uzMzD0Baj6khikexTSTdhDpFJjiEfMFvhtNVzXjbf53M9NQF0QXhOCqDxd7L9_bbow1PfpfKIbwFYk3JwaQrDOsE1O1dmACkrVVROGEgbdpvJl-JnPdnn9Nn0xgqjq3k9" width="624" />

&nbsp;

If we were to peek at the shared subscription backlog we would see the same set of messages.

Now, let’s connect the exclusive consumer. That consumer receives its copy of the six messages, but Pulsar holds the other six copies of the messages in the backlog until one or more of the shared consumers connects to the subscription:

<img height="183" src="https://lh5.googleusercontent.com/9O29Jje_Vi9k8w96C4BWnqkMBFO_fSiEiqRzPTA11HLoQBu08Hs9MVSY4OLRIQqkIw989oJotxtUw75cKkOEJF2II7p4zx24jxHIcjiGStSAxzqVhcQabgOWJnScMvD-NeoUUMfT" width="624" />

<h3>Conclusion</h3>

As you can see, Pulsar provides a simple way to connect multiple groups of consumers to a topic using subscriptions. With subscriptions you can fan-out messages published to a topic to multiple consuming applications. Because Pulsar supports different types of subscriptions, different applications can connect to a single topic and consume messages in different ways. All of this is handled automatically by the Pulsar broker and client library. There is no need for special code in your application.

Pulsar subscriptions are powerful and give you a great deal of flexibility for consuming from topics. They also support advanced features such as rewind and skip. Look for a future post on these advanced features of Pulsar subscriptions to continue your learning.

Want to try out Apache Pulsar?&nbsp;<a href="https://astra.datastax.com/register">Sign up now</a>&nbsp;for&nbsp;<a href="https://www.datastax.com/products/astra-streaming">Astra Streaming</a>, our fully managed Apache Pulsar service. We’ll give you access to its full capabilities entirely free through beta. See for yourself how easy it is to build modern data applications and let us know what you’d like to see to make your experience even better.&nbsp;

(Editor's note: <a href="https://www.datastax.com/press-release/datastax-delivers-scale-out-enterprise-event-streaming-modern-data-apps">DataStax acquired Kesque in January 2021</a>.)

Subscriptions: Multiple Groups of Consumers on a Pulsar Topic

Chris Bartholomew

Share

More Company

DataStax Astra DB Nabs Three Prestigious 2023 TrustRadius “Best of” Awards, Dominates the Vector Databases Category

DataStax Has Achieved ISO 27001 Certification

Keeping the Momentum Rolling with Google Cloud

My Internship Journey: A Dive into AI

NoSQL and Vector DB
for Generative AI,
Instantly, At Scale

Chris Bartholomew

Share

More Company

DataStax Astra DB Nabs Three Prestigious 2023 TrustRadius “Best of” Awards, Dominates the Vector Databases Category

DataStax Has Achieved ISO 27001 Certification

Keeping the Momentum Rolling with Google Cloud

My Internship Journey: A Dive into AI

NoSQL and Vector DBfor Generative AI,Instantly, At Scale

NoSQL and Vector DB
for Generative AI,
Instantly, At Scale