Fixed logical error while initialization in factory

yugabyte · Jul 17, 2023 · 8bdc6a3 · 8bdc6a3
1 parent 3c1e5a8
commit 8bdc6a3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/debezium/connector/yugabytedb/YugabyteDBChangeEventSourceFactory.java b/src/main/java/io/debezium/connector/yugabytedb/YugabyteDBChangeEventSourceFactory.java
@@ -86,7 +86,7 @@ public SnapshotChangeEventSource<YBPartition, YugabyteDBOffsetContext> getSnapsh
     @Override
     public StreamingChangeEventSource<YBPartition, YugabyteDBOffsetContext> getStreamingChangeEventSource() {
         LOGGER.info("Transaction ordering enabled: {}", configuration.transactionOrdering());
-        if (configuration.transactionOrdering()) {
+        if (!configuration.transactionOrdering()) {
             LOGGER.info("Instantiating Vanilla Streaming Source");
             return new YugabyteDBStreamingChangeEventSource(
                     configuration,