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

DBZ-5987 Removing unnecessary getOffset() call during streaming

Browse Source
This commit is contained in:
jcechace 2023-03-16 11:57:03 +01:00 committed by Jiri Pechanec
parent a536952779
commit a393930de9
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbStreamingChangeEventSource.java
View File

@ -168,7 +168,6 @@ private void readChangeStream(MongoClient client, ReplicaSet replicaSet, ChangeE
LOGGER.trace("Arrived Change Stream event: {}", event);
rsOffsetContext.changeStreamEvent(event);
rsOffsetContext.getOffset();
CollectionId collectionId = new CollectionId(
replicaSet.replicaSetName(),
event.getNamespace().getDatabaseName(),