SourceOpen-Source

Ingest data from Apache Pulsar

Apache Pulsar is an open-source distributed messaging and streaming platform

Quick Start

Connect in minutes with SQL

Use CREATE SOURCE or CREATE TABLE to ingest data from Apache Pulsar into RisingWave. No plugins, no middleware — just PostgreSQL-compatible SQL.

SQL

CREATE SOURCE IF NOT EXISTS orders_rw (
    order_id INTEGER PRIMARY KEY,
    customer_id INTEGER,
    order_status VARCHAR,
    total_amount DECIMAL,
    last_updated TIMESTAMP)
WITH (
   connector='pulsar',
   topic='demo_topic',
   service.url='pulsar://localhost:6650/',
   oauth.issuer.url='https://auth.streamnative.cloud/',
   oauth.credentials.url='s3://bucket_name/your_key_file.file',
   oauth.audience='urn:sn:pulsar:o-d6fgh:instance-0',
   aws.credentials.access_key_id='aws.credentials.access_key_id',
   aws.credentials.secret_access_key='aws.credentials.secret_access_key',
   scan.startup.mode='latest',
   scan.startup.timestamp.millis='140000000'
) FORMAT PLAIN ENCODE AVRO (
   message = 'message',
   schema.location = 'https://demo_bucket_name.s3-us-west-2.amazonaws.com/demo.avsc'
);

For comprehensive configuration details, please refer to the Pulsar connector documentation.

Capabilities

What you can do with RisingWave + Apache Pulsar

Real-time Ingestion

Continuously stream data from Apache Pulsar into RisingWave with sub-second latency. Process millions of events per second.

SQL Transformations

Join Apache Pulsar data with other sources, apply windowing, aggregation, and filtering — all in standard SQL.

Materialized Views

Create incrementally maintained materialized views over Apache Pulsar data. Always fresh, always queryable.

Multi-format Support

Supports Avro, JSON, Protobuf, CSV, and more. Compatible with Schema Registry for schema evolution.

Resources

Learn more

Apache Pulsar Source Connector Documentation

Complete configuration reference, authentication options, and advanced features for the Apache Pulsar source connector.

Apache Pulsar as Destination

RisingWave also supports Apache Pulsar as a destination. View the destination connector.

RisingWave Quick Start Guide

Get RisingWave running locally in 5 minutes and try your first streaming pipeline.

Start streaming in minutes

Connect to Apache Pulsar with just a few lines of SQL. No infrastructure to manage, no code to write.

Start Free All Connectors