Use global state for CDC

airbytehq · Aug 21, 2023 · f7c3e46 · f7c3e46
1 parent 344a9b2
commit f7c3e46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/src/main/java/io/airbyte/integrations/source/mongodb/internal/MongoDbStateIterator.java b/...c/src/main/java/io/airbyte/integrations/source/mongodb/internal/MongoDbStateIterator.java
@@ -112,7 +112,7 @@ public AirbyteMessage next() {
       }
 
       final var stateMessage = new AirbyteStateMessage()
-          .withType(AirbyteStateType.STREAM)
+          .withType(AirbyteStateType.GLOBAL)
           .withStream(streamState);
 
       return new AirbyteMessage().withType(Type.STATE).withState(stateMessage);