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
KafakV2SourceConnector #39410
KafakV2SourceConnector #39410
Conversation
sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/CosmosAsyncContainer.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.
LGTM
/azp run java - cosmos - tests |
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 removing the shaded Guava/commons files - LGTM
Azure Pipelines failed to run 1 pipeline(s). |
/azp run java - cosmos - tests |
Azure Pipelines failed to run 1 pipeline(s). |
/azp run java - cosmos - tests |
Azure Pipelines failed to run 1 pipeline(s). |
87f96bb
to
10f8bca
Compare
/azp run java - cosmos - tests |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run java - cosmos - tests |
Azure Pipelines successfully started running 1 pipeline(s). |
/azp run java - cosmos - tests |
Azure Pipelines successfully started running 1 pipeline(s). |
b518c1f
to
6a25454
Compare
/azp run java - cosmos - tests |
Azure Pipelines successfully started running 1 pipeline(s). |
/*** | ||
* The CosmosDb source connector. | ||
*/ | ||
public class CosmosDBSourceConnector extends SourceConnector { |
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.
should it implement AutoCloseable
?
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.
yea good point, will add in the next PR
flaky tests: tests passed locally: |
/check-enforcer override |
Re-add kafka source v2 connector #38748 and #38884
Extra changes added(mainly to reduce the export packages scope from azure-cosmos):
Added the following methods in azure-cosmos (internal and can be accessed from ImplementationBridgeHelpers).
CosmosChangeFeedRequestOptions
:CosmosAsyncContainer
: