You can use the DataStax Astra Streaming Connector to get data from or send data to an Astra stream. This topic covers how to configure the DataStax Astra Streaming Connector to send data from Decodable into DataStax Astra. If you are looking for information about how to get data from DataStax Astra into Decodable, see DataStax Astra Streaming in the Connect to a data source chapter.
|Delivery guarantee||at least once|
|Compatibility||Pulsar 2.9.x or above|
Follow these steps to create a connection that sends data from Decodable to DataStax Astra.
- From the Connections page, select the DataStax Astra Streaming Connector and complete the following fields.
|UI Field||Property Name in the Decodable CLI||Description|
|Connection Type||N/A||Select sink to use this connector to send data into DataStax Astra.|
|Broker Service URL||The URL to connect to your Astra Streaming broker.|
|Admin Web Service URL||The URL to connect to your Astra Streaming admin endpoint.|
|Topic||The fully-qualified name of the Astra topic.|
|Authentication Token||The JWT web token to use for authentication.|
|Partition Key Columns||A list of fields, delimited by semicolons, that comprise the partition key.|
|Partition Key Format||Optional. The format used to serialize and deserialize the partition key. Must be one of the following:|
|Value Format||The format for data in the Astra topic. Must be one of the following:|
|Partition Key Inclusion Policy||Specify whether the partition key columns should be present in the payload values sent to Astra.|
For an example of how the
Select the stream that you’d like to connect to this connector. Then, select Next.
Define the connection’s schema. Decodable can auto-populate the connection’s schema using Pulsar's schema registry. In most cases, you’ll want to select Schema Registry to automatically populate the connection’s schema. However, if you would like to manually enter the schema, select New Schema or Structured Schema Definition.
- If you want to auto-populate the connection schema using Pulsar's schema registry, you’ll also need to provide the name of your Pulsar tenant, the namespace where your topic is, and the version of the schema that you’d like to use.
Select Next when you are finished providing defining the connection’s schema.
Give the newly created connection a Name and Description and select Save.
Updated about 1 month ago