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™.
Connecting Apache Pulsar™ to DataStax Astra
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
sensor-data in the
pulsar-admin topics create persistent://public/default/sensor-data
Verify that the new topic exists:
pulsar-admin topics list public/default