[
https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448010#comment-17448010
]
Arvid Heise commented on FLINK-24905:
-------------------------------------
Table API is not giving a strong guarantee for state upgrades in 1.14 but that
may change later. So to be safe, it would be awesome if the state can be
migrated (if there is any).
We should keep options aligned between the versions, you can use fallback keys
to maintain backward compatibility.
I don't see a need to support the old connector unless some features are yet to
be migrated. If they really want to use the old connector, they can just use
sql-connector-kinesis-1.14.jar. In the end, we want to get rid of the old
connector rather sooner than later and then the option
{{sink.use-kinesis-producer}} is deprecated. This may cause more friction than
having a drop-in replacement.
> KDS implementation of Async Sink Table API
> ------------------------------------------
>
> Key: FLINK-24905
> URL: https://issues.apache.org/jira/browse/FLINK-24905
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Kinesis
> Reporter: Zichen Liu
> Assignee: Ahmed Hamdy
> Priority: Major
> Fix For: 1.15.0
>
>
> h2. Motivation
> *User stories:*
> As a Flink user, I’d like to use the Table API for the new Kinesis Data
> Streams sink.
> *Scope:*
> * Introduce {{AsyncDynamicTableSink}} that enables Sinking Tables into Async
> Implementations.
> * Implement a new {{KinesisDynamicTableSink}} that uses
> {{KinesisDataStreamSink}} Async Implementation and implements
> {{{}AsyncDynamicTableSink{}}}.
> * The implementation introduces Async Sink configurations as optional
> options in the table definition, with default values derived from the
> {{KinesisDataStream}} default values.
> * Unit/Integration testing. modify KinesisTableAPI tests for the new
> implementation, add unit tests for {{AsyncDynamicTableSink}} and
> {{KinesisDynamicTableSink}} and {{{}KinesisDynamicTableSinkFactory{}}}.
> * Java / code-level docs.
> h2. References
> More details to be found
> [https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
