-
Notifications
You must be signed in to change notification settings - Fork 12
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
50 migrate to new sdk #51
Conversation
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.
Some initial thoughts. The diff is (unnsurprisingly) quite challenging so maybe you can address these and then I can take another look.
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.java
Outdated
Show resolved
Hide resolved
src/main/java/com/ibm/cloudant/kafka/connect/CloudantSourceTask.java
Outdated
Show resolved
Hide resolved
.build(); | ||
Response<Ok> result = service.deleteDatabase(deleteDbOptions).execute(); | ||
if (!result.getResult().isOk()) { | ||
LOG.error(String.format("Error during deletion of database %s. Error code: %d Error response: %s", |
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.
What is the motivation for logging in the test vs just failing?
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.
I removed this log and added an assertion in df22ab8
45ef249
to
df22ab8
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.
The copyright dates need a refresh frrom 2021 to 2022 and a couple of minor new questions, but otherwise this is looking OK to swap the client out ready for future improvements.
src/main/java/com/ibm/cloudant/kafka/common/utils/JavaCloudantUtil.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.
+1, a changelog nit sorry I didn't spot it earlier.
I think this will be ok to merge if you are satisified with your testing outcomes.
Co-authored-by: Rich Ellis <ricellis@users.noreply.github.com>
Checklist
CHANGES.md
|CHANGELOG.md
) or test/build only changesDescription
fixes #50
The underlying Cloudant client library is now EOL. This PR refactored the codebase and tests to use the new
cloudant-java-sdk
library.Approach
Schema & API Changes
"No change"
Security and Privacy
Testing
Updated existing tests to use new library.
No new tests.
Monitoring and Logging