Ingest data from Amazon Kinesis
Amazon Kinesis cost-effectively processes and analyzes streaming data at any scale as a fully managed service.
Quick Start
Connect in minutes with SQL
Use CREATE SOURCE or CREATE TABLE to ingest data from Amazon Kinesis into RisingWave. No plugins, no middleware — just PostgreSQL-compatible 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='kinesis',
stream='kafka',
aws.region='user_test_topic',
endpoint='172.10.1.1:9090,172.10.1.2:9090',
aws.credentials.session_token='AQoEXAMPLEH4aoAH0gNCAPyJxz4BlCFFxWNE1OPTgk5TthT+FvwqnKwRcOIfrRh3c/L To6UDdyJwOOvEVPvLXCrrrUtdnniCEXAMPLE/IvU1dYUg2RVAJBanLiHb4IgRmpRV3z rkuWJOgQs8IZZaIv2BXIa2R4OlgkBN9bkUDNCJiBeb/AXlzBBko7b15fjrBs2+cTQtp Z3CYWFXG8C5zqx37wnOE49mRl/+OtkIKGO7fAE',
aws.credentials.role.arn='arn:aws-cn:iam::602389639824:role/demo_role',
aws.credentials.role.external_id='demo_external_id',
aws.credentials.access_key_id = 'your_access_key',
aws.credentials.secret_access_key = 'your_secret_key'
) FORMAT PLAIN ENCODE AVRO (
schema.location = 'https://demo_bucket_name.s3-us-west-2.amazonaws.com/demo.avsc'
);For comprehensive configuration details, please refer to the Kinesis connector documentation.
Capabilities
What you can do with RisingWave + Amazon Kinesis
Real-time Ingestion
Continuously stream data from Amazon Kinesis into RisingWave with sub-second latency. Process millions of events per second.
SQL Transformations
Join Amazon Kinesis data with other sources, apply windowing, aggregation, and filtering — all in standard SQL.
Materialized Views
Create incrementally maintained materialized views over Amazon Kinesis 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
Complete configuration reference, authentication options, and advanced features for the Amazon Kinesis source connector.
RisingWave also supports Amazon Kinesis as a destination. View the destination connector.
Get RisingWave running locally in 5 minutes and try your first streaming pipeline.
Start streaming in minutes
Connect to Amazon Kinesis with just a few lines of SQL. No infrastructure to manage, no code to write.
