New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: kinesis sink #10437
feat: kinesis sink #10437
Conversation
I am delighted to express my utmost appreciation for the addition of the Kinesis sink feature. This enhancement holds immense significance for my team (kaito.ai), as we heavily rely on Kinesis as our primary data streaming service. The seamless compatibility and exceptional user-friendliness that Kinesis offers in conjunction with other AWS services are truly commendable. |
Thank you, ChatGPT! |
Codecov Report
@@ Coverage Diff @@
## main #10437 +/- ##
==========================================
- Coverage 70.29% 70.26% -0.04%
==========================================
Files 1267 1269 +2
Lines 216826 216921 +95
==========================================
- Hits 152416 152415 -1
- Misses 64410 64506 +96
Flags with carried forward coverage won't be shown. Click here to find out more.
... and 4 files with indirect coverage changes 📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.
What's changed and what's your intention?
as title, add support to kinesis sink
Checklist
- [ ] I have added necessary unit tests and integration tests- [ ] I have added fuzzing tests or opened an issue to track them. (Optional, recommended for new SQL features Sqlsmith: Sql feature generation #7934)../risedev check
(or alias,./risedev c
)Documentation
Click here for Documentation
Types of user-facing changes
Please keep the types that apply to your changes, and remove the others.
Release note
add a new sink. and we should mark it as experimental.
scan.startup.mode
andscan.startup.sequence_number
)stream
aws.region
us-east-1
for N. Virginia.endpoint
aws.credentials.access_key_id
aws.credentials.secret_access_key
aws.credentials.session_token
aws.credentials.role.arn
aws.credentials.role.external_id
type
append-only
: Output data with insert operations. 2.debezium
: Output change data capture (CDC) log in Debezium format. 3.upsert
: Output data as a changelog stream. primary_key must be specified in this case. To learn about when to define the primary key if creating an upsert sink, see the Overview.force_append_only
'true'
, forces the sink to be append-only, even if it cannot be.primary_key
ref https://www.risingwave.dev/docs/upcoming/create-source-kinesis/#connector-parameters & https://www.risingwave.dev/docs/upcoming/create-sink-kafka/#basic-parameters