DBZ-6730 Exit consumption loop if engine has stopped

2023-07-31 03:25:08 -04:00 · 2023-07-31 03:25:08 -04:00 · 58792c4a7c
commit 58792c4a7c
parent fd1e60bf92
1 changed files with 1 additions and 1 deletions
--- a/debezium-embedded/src/test/java/io/debezium/embedded/AbstractConnectorTest.java
+++ b/debezium-embedded/src/test/java/io/debezium/embedded/AbstractConnectorTest.java
@ -542,7 +542,7 @@ protected int consumeRecordsUntil(BiPredicate<Integer, SourceRecord> condition,
        int recordsConsumed = 0;
        int nullReturn = 0;
        boolean isLastRecord = false;
-        while (!isLastRecord) {
+        while (!isLastRecord && engine.isRunning()) {
            SourceRecord record = consumedLines.poll(pollTimeoutInMs, TimeUnit.MILLISECONDS);
            if (record != null) {
                nullReturn = 0;