alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2138 Handle lsid as Binary for MongoDB 4.2

Browse Source
This commit is contained in:
Jiri Pechanec 2020-11-27 10:26:11 +01:00 committed by Gunnar Morling
parent e8aecd7b45
commit 349fcdad07
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtil.java
View File

@ -15,6 +15,7 @@
import java.util.regex.Pattern;
import org.bson.Document;
import org.bson.types.Binary;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoClient;
@ -230,7 +231,10 @@ public static String getOplogSessionTransactionId(Document oplogEvent) {
if (!oplogEvent.containsKey("txnNumber")) {
return null;
}
final String lsid = oplogEvent.get("lsid", Document.class).get("id", UUID.class).toString();
final Document lsidDoc = oplogEvent.get("lsid", Document.class);
final Object id = lsidDoc.get("id");
// MongoDB 4.2 returns Binary instead of UUID
final String lsid = (id instanceof Binary) ? UUID.nameUUIDFromBytes(((Binary) id).getData()).toString() : ((UUID) id).toString();
final Long txnNumber = oplogEvent.getLong("txnNumber");
return lsid + ":" + txnNumber;
}