Karthi Thyagarajan created FLINK-30777:
------------------------------------------
Summary: Allow Kinesis Table API Connector to specify shard
assigner
Key: FLINK-30777
URL: https://issues.apache.org/jira/browse/FLINK-30777
Project: Flink
Issue Type: Bug
Components: Connectors / Kinesis
Reporter: Karthi Thyagarajan
As a follow up to the fix involving UniformShardAssigner
(https://issues.apache.org/jira/browse/FLINK-24639), it would be good to allow
users to pick something other than the default shard assigner, such as the
recently introduced UniformShardAssigner.
This can be accomplished by introducing a new connector option called
'shard-assigner.' Something like below; note the introduction of a new option
called 'shard-assigner'
{{CREATE TABLE KinesisTable ( `user_id` BIGINT, `item_id` BIGINT,
`category_id` BIGINT, `behavior` STRING, `ts` TIMESTAMP(3))PARTITIONED BY
(user_id, item_id)WITH ( 'connector' = 'kinesis', 'stream' = 'user_behavior',
'aws.region' = 'us-east-2', 'scan.stream.initpos' = 'LATEST', 'format' =
'csv', 'shard-assigner' = 'uniform');}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
