[
https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kailash Hassan Dayanand updated FLINK-8945:
-------------------------------------------
Summary: Allow customization of the KinesisProxy (was: Allow customization
of the KinesisProxy Interface)
> Allow customization of the KinesisProxy
> ---------------------------------------
>
> Key: FLINK-8945
> URL: https://issues.apache.org/jira/browse/FLINK-8945
> Project: Flink
> Issue Type: Improvement
> Reporter: Kailash Hassan Dayanand
> Priority: Minor
>
> Currently the KinesisProxy interface here:
> [https://github.com/apache/flink/blob/310f3de62e52f1f977c217d918cc5aac79b87277/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java#L125]
> has a private constructor. This restricts extending the class and prevents
> customizations on shard discovery. I am proposing to change this to protected.
> While the creating a new implementation of KinesisProxyInterface is possible,
> I would like to continue to use implementation of getRecords and
> getShardIterator.
> This will be a temporary workaround till FLINK-8944 is submitted.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
