DataStax Streaming Learning
The learning site is a collection of guides and articles about DataStax streaming products. Each product has its own area dedicated to providing specifics to get started, its features, and other details. The learning site helps you get the most out of each product and get to production using best practices.
APIs & References
Connectors
A connector is a function that moves data between Apache Pulsar and external systems. Source are used to push data to Pulsar from external systems such as databases, message queues, and storage systems. Sinks are used to pull data from a Pulsar topic to an external system like a database, data warehouse, or storage system.
Sources | Sinks | Experimental
Pulsar Functions
Functions are lightweight compute processes that enable you to process each message received on a topic. You can apply custom logic to that message, transforming or enriching it, and then output it to a different topic.
Learn more
Transformation Functions
Transform functions are a low-code implementation of common Pulsar functions. They are used to transform messages from one format to another. Use them to transform a message, enrich messages with additional data, or filter messages based on their content.
Cast | Compute | Drop | Flatten | Merge | Unwrap
Topic Subscriptions
Subscriptions in Pulsar describe which consumers are consuming data from a topic and how they want to consume that data.
Exclusive | Shared | Failover | Key Shared