-
Notifications
You must be signed in to change notification settings - Fork 3.5k
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
Fix kinesis sink backoff class not found #10744
Fix kinesis sink backoff class not found #10744
Conversation
* All variables are in TimeUnit millis by default. | ||
*/ | ||
@Data | ||
public class Backoff { |
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.
this class is becoming part of the Public API.
please annotate it with Stability annotations.
Can't you move this class to the Kinesis connector module ?
I had a similar discussion with @vroyer that wanted to add a SslConfig class in the public Pulsar IO package.
those additions should be done with care because once we add something to the public API we have to maintain it in the future
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.
Yes, I think you are right, it seems that not all connectors need this class. I move it to the project Kinesis connector.
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
* copy the class `Backoff` to the project Kinesis connector
* copy the class `Backoff` to the project Kinesis connector
* copy the class `Backoff` to the project Kinesis connector (cherry picked from commit e19f647)
* copy the class `Backoff` to the project Kinesis connector
Motivation
Currently, the class
Backoff
in the project Pulsar client impl, the Kinesis sink connector want to use this class, the dependencyorg.apache.pulsar:pulsar-client-original
is needed, but this will increase the connector size, so we could add a new classBackoff
in the function io-core, then the classBackoff
could be reused by other connectors.Modifications
Add the class
Backoff
in the project function io-core.Verifying this change
Does this pull request potentially affect one of the following parts:
If
yes
was chosen, please highlight the changes