jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

[Source-mongo] : Migrate to Kotlin (#36845)

Browse Source
This commit is contained in:
Akash Kulkarni
2024-04-04 17:29:23 -07:00
committed by GitHub
parent 814d95cfbb
commit 4a020a4078
8 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
airbyte-integrations/connectors/source-mongodb-v2/build.gradle
View File

@@ -3,7 +3,7 @@ plugins {
}
airbyteJavaConnector {
cdkVersionRequired = '0.28.0'
cdkVersionRequired = '0.29.2'
features = ['db-sources', 'datastore-mongo']
useLocalCdk = false
}

2
airbyte-integrations/connectors/source-mongodb-v2/metadata.yaml
View File

@@ -5,7 +5,7 @@ data:
connectorSubtype: database
connectorType: source
definitionId: b2e713cd-cc36-4c0a-b5bd-b47cb8a0561e
dockerImageTag: 1.3.1
dockerImageTag: 1.3.2
dockerRepository: airbyte/source-mongodb-v2
documentationUrl: https://docs.airbyte.com/integrations/sources/mongodb-v2
githubIssueLabel: source-mongodb-v2

3
airbyte-integrations/connectors/source-mongodb-v2/src/main/java/io/airbyte/integrations/source/mongodb/cdc/MongoDbCdcTargetPosition.java
View File

@@ -13,6 +13,7 @@ import io.airbyte.commons.json.Jsons;
import io.debezium.connector.mongodb.ResumeTokens;
import java.util.Map;
import java.util.Objects;
import javax.annotation.Nullable;
import org.bson.BsonDocument;
import org.bson.BsonTimestamp;
import org.slf4j.Logger;
@@ -88,7 +89,7 @@ public class MongoDbCdcTargetPosition implements CdcTargetPosition<BsonTimestamp
}
@Override
public boolean isSameOffset(final Map<String, String> offsetA, final Map<String, String> offsetB) {
public boolean isSameOffset(@Nullable final Map<String, String> offsetA, @Nullable final Map<String, String> offsetB) {
if (offsetA == null || offsetA.size() != 1) {
return false;
}