Difficulty: Intermediate
Estimated Time: 20 minutes

This scenario demonstrates how to deliver data from Pulsar topics into Astra tables using DataStax Apache Pulsar Connector. The connector can also be used to deliver data into Apache Cassandra™ and DataStax Enterprise.

In this scenario, you will:

  • Create a Pulsar topic and an Astra/Cassandra table
  • Install DataStax Apache Pulsar Connector and create a sink instance
  • Publish messages to the topic and retrieve the corresponding rows from the table

Check out our datastax.com/dev site, where you can find many more resources to help you succeed with Apache Cassandra™.

In this scenario, you learned how to:

  • Create a Pulsar topic and an Astra/Cassandra table
  • Install DataStax Apache Pulsar Connector and create a sink instance
  • Publish messages to the topic and retrieve the corresponding rows from the table

Connecting Apache Pulsar™ to DataStax Astra

Step 1 of 7

Create a topic in Pulsar

To publish messages to Pulsar, we need to create a topic that can serve as a channel to pass messages from producers to consumers. In this example, we use topic sensor-data that belongs to namespace default and tenant public.

Create topic sensor-data in the public/default namespace:

pulsar-admin topics create persistent://public/default/sensor-data

Verify that the new topic exists:

pulsar-admin topics list public/default