DBZ-4321 Add debugging

debezium · Dec 12, 2023 · c104829 · c104829
1 parent 8c17c8c
commit c104829
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/test/java/io/debezium/connector/informix/InformixReselectColumnsProcessorIT.java b/src/test/java/io/debezium/connector/informix/InformixReselectColumnsProcessorIT.java
@@ -111,4 +111,10 @@ protected void waitForStreamingStarted() throws InterruptedException {
     private void setRecordsWaitTimeAfterNulls() {
         System.setProperty(RECORDS_WAITTIME_AFTER_NULLS, System.getProperty(RECORDS_WAITTIME_AFTER_NULLS, "120"));
     }
+
+    protected SourceRecords consumeRecordsByTopicReselectWhenNullStreaming() throws InterruptedException {
+        SourceRecords records = super.consumeRecordsByTopicReselectWhenNullStreaming();
+        records.allRecordsInOrder().forEach(System.out::println);
+        return records;
+    }
 }