-
Notifications
You must be signed in to change notification settings - Fork 51
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
[FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff strategies #165
Conversation
...connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java
Show resolved
Hide resolved
...c/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the PR @karubian. Left some comments
… for retry and backoff
5b5de7e
to
570f3d2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM - Thanks @karubian for the contribution!
@Experimental | ||
public class KinesisStreamsSourceConfigConstants { | ||
@PublicEvolving |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hmmm, there's no point having both here - Only 1 is required. Because this connector is still @Experimental
we can keep it that way 👀
Purpose of the change
Port over Kinesis Client configurations for retry and backoff
Contains the changes from this PR: #150
Verifying this change
Significant changes
(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)
@Public(Evolving)
)